卡夫卡消费消息的不同方式 - 何时使用哪一种？

Question

我是新来的信息功能以及Aapache kafka.I是在其方案中使用其API消费者困惑，我看到有两个可用的客户端库

kafka_2.11_0.10.11和卡夫卡的客户端 - 0.10 .1.1

第一个使用稍微

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

和在第二个

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

是否采取这些e两个API服务器用途不同？

Answer 1

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