我注意到从Kafka 0.8.2.0开始,Kafka附带了一个新的maven模块:
http://mvnrepository.com/artifact/org.apache.kafka/kafka-clients
<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.0</version>
</dependency>
但是,它仍然与较旧的Maven模块一起提供
<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.11</artifactId>
<version>0.8.2.0</version>
</dependency>
这两个模块之间有什么区别或关系?我注意到之前使用过的SimpleConsumer在kafka_2.11
模块中,但不在中kafka-clients
,这是否意味着如果我想使用SimpleConsumer,我仍然必须包括kafka_2.11模块吗?
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句