ConsumerConnector には 2 つの定義があります: a) kafka.javaapi.consumer.ConsumerConnector b) kafka.consumer.ConsumerConnector </p>
違いを説明してくれる人はいますか?ありがとう!
また、ConsumerConnector を使用して KafkaStream を取得する場合、コンシューマ オフセットはどこに保持されますか? 私が ConsumerConnector を作成するとき、それでも Zookeeper の URL を提供するように求められるためです。