Kafka 流与 Kafka 消费者和 Java 流 API

Question

我是 Kafka Stream 的新手。我想知道通过使用 kafka 流 API 而不是使用标准的 kafka 生产者/消费者 API 并使用 Java 流 API 在消费者中进行流处理可以获得什么好处。

Answer 1

Java Stream API 与Kafka API 无关。您可以从消费者轮询迭代器执行 consumerRecords.forEach，或从 Java 流调用生产者发送方法，仅此而已。

Kafka Streams API 允许您更轻松地 map/filter/branch/join 主题数据，以及访问持久性 StateStores。它也有 foreach 和 peek 方法，我想你指的是什么？与任何 Kafka Streams 方法相比，您在向消费者 API 提交偏移量时拥有更直接的访问权限。

对于生产者，您不能使用 Kafka Streams API 将原始数据生产到主题中。