java - 合适的 Apache Kafka 客户端 jar 是什么

有人可以告诉我 jar 之间的区别吗 1和 2 。我正在尝试编写 kafka 客户端，使用 KafkaConsumer 上的 poll(long timeout) API 从代理中提取数据 1但实现似乎是自动生成的。(见下文)。关于什么是正确的 jar 的任何想法。

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

最佳答案

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

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

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

关于java - 合适的 Apache Kafka 客户端 jar 是什么，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/41386372/