Clickhouse版本21.12.3.32。我m following this PR([https://github.com/ClickHouse/ClickHouse/pull/21850](https://github.com/ClickHouse/ClickHouse/pull/21850)) to handle incorrect messages from kafka
浏览 43提问于2022-03-16得票数 0
回答已采纳
我试着将一些实时指标从kafka放到clickhouse，我的查询如下所示
CREATE TABLE queue2 (timestamp String, namespace String, data Float, unit String, plugin_running_on String, version UInt64, last_advertised_time String) ENGINE = Kafka('10.224.54.99:9092', 'outtopic1',
浏览 27提问于2018-01-03得票数 0
回答已采纳
我有两个(以及更多) Kafka主题，我需要加入他们。我的问题来自我在博客/StackOverflow上读到的内容...有两个选项： 1)将它们都流式传输，Clickhouse Kafka引擎/spark流，然后运行join，这在Clickhouse中是不推荐的2)构建一个包含所有列的表，并使用Clickhouse引擎/spark streaming更新相同的入口？ 任何建议
浏览 22提问于2019-03-06得票数 1
出于测试目的，我必须将数据从Clickhouse服务器推送到Kafka。我已经尝试过使用Confluent JDBC连接器，但效果不是很好。看起来Clickhouse- Kafka -Engine只在Kafka -> Clickhouse方向上工作，所以Clickhouse-server作为消费者工作。在Clickhouse中使用Table作为生产者有没有一个方便的方法，或者我有没有自己写生产者？
浏览 3提问于2018-12-30得票数 1
我正在尝试使用Clickhouse Kafka引擎来摄取数据。数据采用CSV格式。在数据摄入过程中，有时我会遇到异常。const&, int)+0x1f) [0x144a02f]3. clickhouse-server(DB::CSVRowInputStream. clickhouse-server(DB::KafkaBlockInputStream::readImpl()
浏览 6提问于2018-01-08得票数 1
回答已采纳
我使用clickhouse数据库来加载一些实时的metrics..so，我用kafka引擎创建了一个表，我将大约100万项指标加载到it...but中，问题是如果我重新启动了clickhouse客户端，如果我确实从表名中选择了*，我就无法看到加载在it..how中的数据，我能看到数据吗？Float, unit String, plugin_running_on String, version UInt64, last_advertised_time S
浏览 0提问于2018-01-25得票数 0
回答已采纳
Clickhouse版本21.7.2.7 kafka_topic_list = 'topic', kafka_format = &
浏览 21提问于2022-02-16得票数 0
回答已采纳
Kafka和Clickhouse在Docker中运行。我正在尝试通过JDBC Connect从Kafka流中插入一些数据到ClickHouse表中。从流中查询数据显示，数据在stream.Then I create Clickhouse表中，其字段与Kafka流中的字段相同 CREATE TABLE IF NOT EXISTS default.tableCREATE SOURCE CONNECTOR
浏览 23提问于2020-11-24得票数 0
回答已采纳
3回答
我目前的日志管理系统使用Kafka-HDFS-钻机基础设施，但我在钻-HDFS交互方面遇到了很大的麻烦。我试图实现的功能是保存日志，并通过一些过滤器为一个客户端请求日志。UPD：logTimestamp longmessage String
因此，系统应该能够通过cli
浏览 0提问于2016-10-26得票数 2
-02: hostname: clickhouse-02 image: yandex/clickhouse-server container_name: clickhouse:2181 clickhouse
浏览 257提问于2019-06-23得票数 1
如果是平面JSON文档，Clickhouse肯定可以从Kafka读取JSON消息。) ENGINE = Kafka
SETTINGS kafka_broker_list = 'kafka1test.intra:9092,kafka2test.intra:9092,kafka3
浏览 8提问于2020-08-21得票数 7
较长版本：
到目前为止，这一切都很有效。我第一次遇到瓶颈时，我加快了输入数据的速度(40万点/秒)，我的制作人无法足够快地写到kafka，
浏览 1提问于2019-01-14得票数 2
回答已采纳
主要目的是将卡夫卡主题的数据转换为Clickhouse表。我想，为什么不使用Clickhouse卡夫卡引擎呢？好吧，有。我试过去，但一切都一样。因此，我决定使用Kafka，但得到了一个错误：
没有为jdbc:clickhouse://localhost找到合适的驱动程序:8123/默认在java.sql.DriverManager.getConnection我找到了，并将clickhouse-jdbc-0.2.4.jar从“release
浏览 4提问于2020-03-06得票数 0
回答已采纳
在我的工作中，事实表存储在ClickHouse中，维度表存储在MySQL数据库中，因此使用MySQL数据库引擎来连接ClickHouse和MySQL数据库。从ClickHouse SQL运行日志中，我可以发现ClickHouse将从MySQL数据库中获取所需的数据并进行聚合。我的问题是，ClickHouse从MySQL数据库获取
浏览 59提问于2020-11-27得票数 0
我试图从Kafka向ClickHouse添加JSON数据。下面是简化的JSON： ...sendCommChannelTypeId":4, "sendAddress":"789345345945"},}
下面是在ClickHouse中创建表的步骤，使用Kafka引擎创建另一个表，创建物化
浏览 9提问于2020-12-02得票数 2
回答已采纳
ClickHouse卡夫卡引擎可以使用JSONEachRow格式使用来自JSONEachRow主题的压缩JSON消息吗？
它会自动解压缩消息，然后应用JSON解析吗？它需要什么特殊的配置吗？编辑我的问题是通过设置压缩配置压缩主题是否会使ClickHouse无法读取这些消息。
浏览 2提问于2018-11-22得票数 1
回答已采纳
我有一个具有嵌套字段和kafka_handle_error_mode='stream',input_format_import_nested_json=1设置的kafka_handle_error_mode='stream',input_format_import_nested_json=1表的Clickhouse服务器和两个物化视图：
_error='' case，将数据存储到与Engine=Kafka表相同结构的下置表中，Engine=<e
浏览 12提问于2021-12-10得票数 0
我想将一些数据从REST发送到kafka，并将其传递给clickhouse，这将是我的DB。到目前为止，我能够让卡夫卡在当地工作，并将数据从一端传递到另一端。嗯，我可以看到卡夫卡终端使用的数据，使用的是卡夫卡工具。但我的点击室显然没有连接起来。SETTINGS kaf
浏览 6提问于2020-03-19得票数 0
我目前正在从事一个项目，该项目需要从Kafka主题(JSON格式)中摄取数据，并将其直接写入Clickhouse。我遵循了中建议的方法我打算使用这个视图(level2)作为将来任何聚合的基础(例如，在level3)。我能实时摄取来自“level2”的数据吗？
问题2:是否有一种方法可以多次从引擎“1级”
浏览 2提问于2018-07-20得票数 2
回答已采纳
2回答
我需要从Kafka队列(用我的脚本填充它)获取数据到ClickHouse (CH)集群中的每个副本。我创造了：
“进度:1.55
浏览 0提问于2019-02-23得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
