Apache Kafka和Apache Storm集成

问题描述 投票:0回答:1

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

apache-kafka apache-storm
1个回答
0
投票

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

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

© www.soinside.com 2019 - 2024. All rights reserved.