Apache Kafka 和 Apache Storm 集成

Question

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

Answer 1

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

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