ClickHouse Kafka Engine:如何为KafkaEngine升级Kafka消费者版本

ClickHouse Kafka Engine: how to upgrade Kafka consumer version for KafkaEngine

如何升级ClickHouse中Kafka Engine使用的Kafka库版本?

而且,如何知道实际使用的版本?

如果您使用的是共享构建,您或许可以获取所需的 librdkafka DSO 文件并替换旧文件。尽管 ABI 有可能不兼容,因为 librdkafka 甚至还没有稳定版本。否则,只需使用您需要的 librdkafka 重建 ClickHouse。

关于查找当前librdkafka的版本,这里有一个方法,

select * from system.build_options

获得 VERSION_GITHASH 并执行

git ls-tree <VERSION_GITHASH> contrib/librdkafka