我一直在尝试apachekafka开源生产者和消费者数据流。我有一个问题，使用1有什么区别。） KafkaProducer, producer.send 和2.） Streamsbuilder, KafkaStreams 代码？它们不都是Kafka的流数据吗？如果我用 KafkaProducer, producer.send ，我不能实现数据流吗？
KafkaProducer, producer.send
Streamsbuilder, KafkaStreams
vc6uscn91#
您可以使用kafka流进行更复杂的数据处理，因为它提供了高级和低级处理器api。在低级处理器api中，您可以控制记录并创建一个流（拓扑），在该流中，您可以以不同的方式操纵记录，并将其发送到一个或多个输出主题。在高级中，您拥有具有join等功能的k表。这些支持窗口和其他功能，使更多的控制数据被拿起。状态存储也可以在kafka流中使用，这有助于实现状态转换。此外，它还可以在kafka流中轻松地进行水平和垂直扩展
1条答案
按热度按时间vc6uscn91#
您可以使用kafka流进行更复杂的数据处理，因为它提供了高级和低级处理器api。在低级处理器api中，您可以控制记录并创建一个流（拓扑），在该流中，您可以以不同的方式操纵记录，并将其发送到一个或多个输出主题。在高级中，您拥有具有join等功能的k表。这些支持窗口和其他功能，使更多的控制数据被拿起。状态存储也可以在kafka流中使用，这有助于实现状态转换。此外，它还可以在kafka流中轻松地进行水平和垂直扩展