ConsumerConnector 有两种定义:a) kafka.javaapi.consumer.ConsumerConnector b) kafka.consumer.ConsumerConnector</p>
谁能帮我解释一下这些差异?谢谢!
另外,如果我使用 ConsumerConnector 来获取 KafkaStream,那么消费者偏移量将保存在哪里?因为当我创建 ConsumerConnector 时,它仍然要求我提供 zookeeper url。
ConsumerConnector 有两种定义:a) kafka.javaapi.consumer.ConsumerConnector b) kafka.consumer.ConsumerConnector</p>
谁能帮我解释一下这些差异?谢谢!
另外,如果我使用 ConsumerConnector 来获取 KafkaStream,那么消费者偏移量将保存在哪里?因为当我创建 ConsumerConnector 时,它仍然要求我提供 zookeeper url。