使用 Apache Kafka 流生成器

【问题标题】：Use of Apache Kafka stream builder使用 Apache Kafka 流生成器
【发布时间】：2018-03-16 04:09:00
【问题描述】：

我一直在尝试 Apache Kafka 开源生产者和消费者数据流。我有一个问题，使用 1.) KafkaProducer, producer.send 和 2.) Streamsbuilder, KafkaStreams 代码？它们不是都用于kafka流数据吗？如果我只使用KafkaProducer, producer.send，我不能实现数据流吗？

【问题讨论】：

你到底想达到什么目的？

标签： apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams

【解决方案1】：

您可以使用 Kafka Streams 进行更复杂的数据处理，因为它提供了高级和低级处理器 API。在低级处理器 API 中，您可以控制记录并创建一个流（拓扑），您可以在其中操作记录不同的方式并将其发送到一个或多个输出主题。在高层次上，您拥有具有连接等功能的 k 表。这些支持窗口和其他功能，可以更好地控制正在拾取的数据。状态存储在 Kafka Streams 中也可用，有助于进行状态转换。此外，它易于在 Kafka 流中水平和垂直扩展

【讨论】：

太棒了！我也在某处读过另一点，Kafka 流 API 是支持排队流数据的 API（例如：连续提要等），标准 API 不支持此类数据流。
Kiran，如果你有解释的链接和文件，你能不能也分享一下？我可以完全阅读所有功能差异。谢谢你的回答。