Kafka 消费消息的不同方式——什么时候使用哪一种？

Question

我是 Messaging 和 Aapache 的新手 kafka.I 对在哪种情况下使用哪个 Consumer API 感到困惑，我看到有两个可用的客户端库

kafka_2.11_0.10.11 和 kafka-clients-0.10.1.1

第一个有点用

ConsumerConnector consumer = kafka.consumer.Consumer.createJavaConsumerConnector...
consumer.createMessageStreams...

第二个

 KafkaConsumer<K,V> consumer = new KafkaConsumer<>(properties);
 consumer.subscribe(...

这两个 API 服务器的用途不同吗？

Answer 1

您应该使用 kafka-clients 库中的实现。主要 Kafka 库中的实现仍然来自旧的实现，并且可能会在未来的版本中删除。

Kafka different ways to consume messages - when to use which one?