kafka.storage文件

uttx8gqw  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(281)

什么是“偏移存储” kafka 0.10.1.1 ?
根据文档,它显示在旧的consumer配置下为“zookeeper”。
偏移量存储zookeeper选择偏移量应该存储的位置(zookeeper或kafka)。
我的消费者是 spring-boot-1.5.13 RELEASE 使用的应用程序 kafka-clients-0.10.1.1 内部。根据源代码consumerconfig.scala,offsetstorage是“zookeeper”,但是当我运行consumer时,我看到 __consumer_offsets “正在创建 /tmp/kafka-logs 中定义的目录 server.properties [即经纪人];
而且它不会出现在 zookeeper 短暂的节点,当我和 zookeeper-shell.sh . ls /consumers [] 如果offsets.stroage是zookeeper,那么为什么在/tmp/kafka日志下会显示\u consumer\u偏移量,而在zookeeper临时节点中不会显示?

lymnna71

lymnna711#

SpringKafka使用“新”消费者(java),而不是旧的scala消费者。

相关问题