1

ConsumerConnector 有两种定义:a) kafka.javaapi.consumer.ConsumerConnector b) kafka.consumer.ConsumerConnector​</p>

谁能帮我解释一下这些差异?谢谢!

另外,如果我使用 ConsumerConnector 来获取 KafkaStream,那么消费者偏移量将保存在哪里?因为当我创建 ConsumerConnector 时,它仍然要求我提供 zookeeper url。

4

0 回答 0