KafkaSpout和KafkaBolt对象有什么区别?通常KafkaSpout用于从kafka生产者那里读取数据,但为什么我们使用KafkaBolt呢?
Storm中的螺栓写入数据。 Spouts是Kafka的消费者。您直接从经纪人处读取,而不是从生产者处读取。
例如,您可以使用Spout读取任何内容,在拓扑中转换该数据,然后设置Kafka Bolt以将数据生成到Kafka