什么是合适的 Apache Kafka Client jar

Question

谁能告诉我罐子之间的区别 1 and 2. I am attempting to write kafka client to pull the data from the brokers using poll(long timeout) API on the KafkaConsumer from 1 但实现似乎是自动生成的。（见下文）。关于什么是正确的罐子的任何想法。

public Map<String, ConsumerRecords<K,V>> poll(long timeout) {
    return null;
}

Answer 1

Kafka 有多种编程语言的客户端。只有 Java 个客户端作为主要 Kafka 项目的一部分进行维护。您可以查看更多关于 clients.

您应该使用第一个 jar 来编写 Kafka 消费者，即

 <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.8.2.0</version>
</dependency>

什么是合适的 Apache Kafka Client jar

What is the appropriate Apache Kafka Client jar

java

apache-kafka

kafka-consumer-api