哪个消费者 API 用于 kafka 0.10.1?

Which consumer API to use for kafka 0.10.1?

我是 Kafka 的新手,我有一个 Kafka leader version 0.10.0 和一个 zookeeper version 3.4.6。我遇到了两种类型的 Kafka 消费者 API:

1. Kafka Polling
2. Kafka Streams

我找不到这两者之间的显着差异。 Kafka 轮询和 Kafka 流式消费者之间有什么区别?适合两者的用例是什么?

感谢任何帮助。

卡夫卡流: KafkaStreams 用于对来自一个主题的数据进行计算,并将计算后的数据发送到另一个主题。 kafkaStreams 在内部同时使用 Producer 和 Consumer。

卡夫卡轮询: kafka 消费者中的 Kafka 轮询从主题及其消费者进程的一部分中获取数据。

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