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允许您更轻松地映射/过滤/分支/连接主题数据，以及访问持久的StateStores。它还有foreach和peek方法，我想你指的是哪个?当你使用Consumer API提交偏移量时，你比任何Kafka Streams方法都有更多的直接访问权限。

对于producer，你不能使用Kafka Streams API将原始数据生成到topic中。