【发布时间】:2014-12-12 15:39:18
【问题描述】:
OpaqueTridentKafkaSpout 和 TransactionalTridentKafkaSpout 有什么区别?您什么时候会使用其中一种?
【问题讨论】:
标签: java message-queue apache-storm apache-kafka trident
OpaqueTridentKafkaSpout 和 TransactionalTridentKafkaSpout 有什么区别?您什么时候会使用其中一种?
【问题讨论】:
标签: java message-queue apache-storm apache-kafka trident
这不是关于哪个更好,而是关于您的要求。
Storm trident 拓扑处理 batches 的元组。
Transactionalstorm spout 保证批次不重叠,并且同一批次将始终包含相同的元组集。 Opaquestorm spout 保证批次不重叠,但批次的内容可能会发生变化。使用哪个取决于您的系统要求和语义。
【讨论】: