consumerconnector有两种定义:a)kafka.javaapi.consumer.consumerconnector b)kafka.consumer.consumerconnector
有人能帮我解释一下区别吗?谢谢!
另外,如果我使用consumerconnector获取kafkastream,消费偏移量将保留在哪里?因为当我创建consumerconnector时,它仍然要求我提供zookeeper url。
consumerconnector有两种定义:a)kafka.javaapi.consumer.consumerconnector b)kafka.consumer.consumerconnector
有人能帮我解释一下区别吗?谢谢!
另外,如果我使用consumerconnector获取kafkastream,消费偏移量将保留在哪里?因为当我创建consumerconnector时,它仍然要求我提供zookeeper url。
暂无答案!
目前还没有任何答案,快来回答吧!