java - 比较不透明或事务性 Kafka spout

Question

OpaqueTridentKafkaSpout和 和有什么不一样TransactionalTridentKafkaSpout？您什么时候会使用其中一种？

Answer 1

这不是关于哪个更好，而是关于您的要求。
Storm trident 拓扑处理batches元组。

• Transactional风暴喷口保证批次不重叠，并且同一批次将始终包含相同的元组集。
• Opaque风暴喷口保证批次不重叠，但批次的内容可能会发生变化。

使用哪个取决于您的系统要求和语义。