KafkaBolt 和 BaseTickTupleAwareRichBolt 的区别

Difference of KafkaBolt and BaseTickTupleAwareRichBolt

KafkaBolt 和 BaseTickTupleAwareRichBolt 有什么区别?每个人具体做什么?它们的优点和缺点是什么?您能为它们分别举一个简单的例子吗?谢谢!

它们没有什么不同,一个包含了另一个的所有优点和缺点

KafkaBolt是BaseTickTupleAwareRichBolt的子类,后者对Kafka一无所知。所以,如果你不需要在 Spout 之外与 Kafka 交互,你就不会使用它。您也可以在 BaseTickTupleAwareRichBolt 实现中定义一个 Kafka 生产者

What exactly do each one do?

其中定义了一个可以从 spout 中检索元组的 Bolt 合约。另一种,具体实现可以配置为与Kafka交互,发送tuple信息给topic