Kafka中的两个Maven模块有什么区别

汤姆

我注意到从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模块吗?

亚历克斯·奥特

SimpleConsumer是Kafka中Consumer的旧版本。现在不推荐使用新的Consumer API。在Kafka 0.8.1中,团队开始重新实现Producer / Consumer API,并进入了kafka-clientMaven工件。您可以跟踪版本之间的变化:0.8.10.9.01.0.0,...

如果您使用的Kafka> = 0.10,则需要使用新的Consumer API。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章