1

ConsumerConnector には 2 つの定義があります: a) kafka.javaapi.consumer.ConsumerConnector b) kafka.consumer.ConsumerConnector </p>

違いを説明してくれる人はいますか?ありがとう!

また、ConsumerConnector を使用して KafkaStream を取得する場合、コンシューマ オフセットはどこに保持されますか? 私が ConsumerConnector を作成するとき、それでも Zookeeper の URL を提供するように求められるためです。

4

0 に答える 0