apache-kafka - KafkaBolt 和 BaseTickTupleAwareRichBolt 的区别

KafkaBolt 和 BaseTickTupleAwareRichBolt 有什么区别？每个人具体是做什么的？它们的优缺点是什么，您能否为它们中的每一个指定一个简单的示例？谢谢！

标签： apache-kafkaapache-storm

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

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

每个人具体是做什么的？

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