apache-kafka - 哪个消费者 API 用于 kafka 0.10.1？

Question

我是 Kafka 新手，我有一个 Kafka 领导者version 0.10.0和一个 zookeeper version 3.4.6。我遇到了两种类型的 Kafka 消费者 API：

1. Kafka Polling
2. Kafka Streams

我无法找到这两者之间的显着差异。Kafka 轮询和 Kafka 流式消费者有什么区别？两者都适用的用例有哪些？

任何帮助表示赞赏。

Answer 1

KafkaStreams：KafkaStreams 用于对来自一个主题的数据进行计算，并将计算的数据发送到另一个主题。在内部，kafkaStreams 都使用 Producer 和 Consumer。

KafkaPolling：Kafka 消费者中的 Kafka 轮询从主题及其消费者进程的一部分中获取数据。

从我的角度来看，如果您只想使用主题中的数据，请使用 kafka 消费者，否则如果您想进行一些计算并将其保存以供进一步使用，请使用 kafka 流。