apache-kafka - Apache Kafka and Apache Storm Integration

Question

What is the difference between KafkaSpout and KafkaBolt object ? Usually KafkaSpout is used for reading data from kafka producers, but why we use KafkaBolt ?

标签： apache-kafkaapache-storm

Answer 1

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

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