0

正如新文档所暗示的那样，默认情况下，Kafka 本身将在使用高级 API 时负责偏移管理。但是当我如下创建一个 ConsumerConnector 时，它仍然需要我提供 zookeeper.connect 属性。

_consumerConnector = Consumer.createJavaConsumerConnector(consumerConfig);

是不是在这种情况下，管理offset的还是zookeeper？谢谢！

4

2 回答 2

1

从 Kafka 开始，0.9偏移量存储在一个特殊的主题__consumer_offsets中。但是，KafkaConsumer仍然依赖于 ZK（出于其他原因）。在未来的版本中，对 ZK 的依赖将被完全删除。

于 2016-10-13T09:42:45.640 回答
0

这看起来仍然是旧的高级消费者 API。您仍然可以使用 Kafka 中的旧 Scala 消费者管理偏移量，但它需要将 offsets.storage 设置为 Kafka，并且您仍然需要 zookeeper。

“新”消费者 api 是一个 java api，确实使用 Kafka 进行偏移存储，并且不需要 zookeeper 连接配置。该 api 记录在这里。

于 2016-10-13T02:04:58.587 回答