我有两个(以及更多) Kafka主题，我需要加入他们。我的问题来自我在博客/StackOverflow上读到的内容...有两个选项： 1)将它们都流式传输，Clickhouse Kafka引擎/spark流，然后运行join，这在Clickhouse中是不推荐的2)构建一个包含所有列的表，并使用Clickhouse引擎/spark streaming更新相同的入口？ 任何建议
浏览 22提问于2019-03-06得票数 1
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
回答已采纳
我试着用clickhouse来冲击卡夫卡的信息。这一切都很好，但是最近我们在kafka主题中添加了一些分区，但是新添加的分区无法被clickhouse检测和使用。是因为clickhouse不支持这个吗？
浏览 3提问于2022-05-23得票数 0
我正在介绍kafka，我想知道如何像这样使用从topic中的分区到ClickHouse表的消息：
当我有3个主题时，很容易将每个主题的表连接起来 kafka_topic_list = 'topic1',
kafka_group_name = 'kafka_g
浏览 1提问于2019-01-15得票数 0
主要目的是将卡夫卡主题的数据转换为Clickhouse表。我想，为什么不使用Clickhouse卡夫卡引擎呢？好吧，有。我试过去，但一切都一样。因此，我决定使用Kafka，但得到了一个错误：
没有为jdbc:clickhouse://localhost找到合适的驱动程序:8123/默认在java.sql.DriverManager.getConnection:321) at org.apache.kafka.connect.runtime.WorkerSi
浏览 4提问于2020-03-06得票数 0
回答已采纳
我正在尝试使用Clickhouse Kafka引擎来摄取数据。数据采用CSV格式。在数据摄入过程中，有时我会遇到异常。const&, int)+0x1f) [0x144a02f]3. clickhouse-server(DB::CSVRowInputStream. clickhouse-server(DB::KafkaBlockInputStream::readImpl()+0x6c) [0x32f6e7c]
7. c
浏览 6提问于2018-01-08得票数 1
回答已采纳
我有一个关于clickhouse中分布式表的问题。假设我有两个带有clickhouse的节点。每个节点都有带有ReplacingMergeTree引擎的数据表(我知道它不能保证完全去重，我对此没有意见)，其中数据从kafka通过kafka引擎表(每个节点从自己的主题读取)。现在，出于某种原因，在每个卡夫卡主题中都有绝对相同的信息。
浏览 28提问于2020-06-28得票数 0
回答已采纳
: "foo:10:1" clickhouse-01: hostname: clickhouse-01 ports: volumes:-02:
image: yandex/clickhous
浏览 257提问于2019-06-23得票数 1
我试着把数据从卡夫卡放到clickhouse的文件里，我的秘密如下所示filebeat.inputs: enabled: true - /var/log/nginx/access.log
# specifying filebeat to take timestamp and message fields,]} %{[message]}'
# publishing to
浏览 1提问于2021-01-01得票数 1
回答已采纳
我试着将一些实时指标从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', 'group2&
浏览 27提问于2018-01-03得票数 0
回答已采纳
我在Kafka中创建了到SQL Server的JDBC连接，数据已成功加载到主题中。如何在Clickhouse中阅读此主题？我用引擎Kafka(关于这个主题)和物化视图创建了一个新表，但没有成功。kafka_broker_list = localhost:9092, kafka_group_name =LOG-END-OFFSET LAG
浏览 105提问于2020-05-21得票数 1
我们使用kafka引擎来连接kafka主题，然后使用物化视图来存储数据。但是有时候，kafka-engine没有使用一些数据(因为我们还应用flume将数据放到hdfs文件中，而这些丢失的数据可以在hdfs文件中找到)。除了升级clcikhouse服务器版本(我们正在升级clickhouse服务器)之外，有没有其他方法可以找到与定位问题相关的日志？
浏览 1提问于2019-12-25得票数 0
是否必须重新启动clickhouse才能读取对users.xml的任何更新？有办法让“重新装”点击屋吗？
浏览 1提问于2017-07-12得票数 2
回答已采纳
我使用使用kafka引擎的队列表中的物化视图将分析数据推送到表中。我使用JSONEachRow作为kafka格式，可能偶尔会出现json解析错误。如何将失败消息移动到死信队列以检查并从处理中跳过？
浏览 5提问于2020-09-11得票数 0
回答已采纳
我把docker和kafka和clickhouse一起使用。我想用'KsqlDB connect‘连接'kafka table’和'clickhouse‘。:8082" image:yandex/clickhouse</
浏览 724提问于2021-11-02得票数 0
回答已采纳
我想从kafka主题消费AvroConfluent格式的消息，并将它们存储在一个点击表中，所以我用kafka引擎创建了一个表，我在表设置中输入了我的模式注册url，但模式注册服务器需要基本的身份验证，我不确定我应该把我的用户信息放在哪里和如何放置像kafka认证配置一样，我试着把我的信息放在config.xml文件中，用于点击房屋服务器，但显然它不起作用
浏览 17提问于2021-09-14得票数 0
Clickhouse版本21.7.2.7 kafka_topic_list = 'topic', kafka_format = 'JSONAsString',<em
浏览 21提问于2022-02-16得票数 0
回答已采纳
出于测试目的，我必须将数据从Clickhouse服务器推送到Kafka。我已经尝试过使用Confluent JDBC连接器，但效果不是很好。看起来Clickhouse- Kafka -Engine只在Kafka -> Clickhouse方向上工作，所以Clickhouse-server作为消费者工作。在Clickhouse中使用Table作为生产者有没有一个方便的方法，或者我有没有自己写生产者？
浏览 3提问于2018-12-30得票数 1
我在向ClickHouse中的Kafka队列添加列时遇到问题。()kafka_broker_list = '172.21.0.3:9092', kafka_group_namenew_column String;SQL Error [48]: ClickHouse exception, code: 48, host: 172.21.0.4,
浏览 4提问于2020-12-17得票数 1
我有一个Kafka流应用程序，它从几个主题中获取数据，并将数据加入到另一个主题中。Kafka配置：Kafka Topics - 15 partitions and 3 replication factor. 在性能和其他因素方面哪个更好?
浏览 2提问于2017-09-14得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
