什么是“偏移存储” 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临时节点中不会显示?
1条答案
按热度按时间lymnna711#
SpringKafka使用“新”消费者(java),而不是旧的scala消费者。