卡夫卡消費消息的不同方式 - 何時使用哪一種？

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庫中的實現仍然來自較早的實現，並且可能在未來版本中刪除。