Apache Kafka 和 Apache Storm 集成

【问题标题】：Apache Kafka and Apache Storm IntegrationApache Kafka 和 Apache Storm 集成
【发布时间】：2023-04-05 01:21:02
【问题描述】：

KafkaSpout 和 KafkaBolt 对象有什么区别？通常 KafkaSpout 用于从 kafka 生产者那里读取数据，但是为什么我们使用 KafkaBolt 呢？

【问题讨论】：

【解决方案1】：

Storm 中的螺栓写入数据。 Spout 是 Kafka 消费者。您直接从经纪人那里阅读，而不是从生产者那里阅读。

例如，您可以使用 Spout 读取任何内容，在拓扑中转换该数据，然后设置 Kafka Bolt 将数据生成到 Kafka 中

【讨论】：