比较不透明或事务性的kafka喷口

gwo2fgha  于 2021-06-09  发布在  Kafka
关注(0)|答案(1)|浏览(357)

两者有什么区别 OpaqueTridentKafkaSpout 以及 TransactionalTridentKafkaSpout ? 你什么时候用一个来代替另一个?

cgvd09ve

cgvd09ve1#

不是哪一个更好,而是你的要求。
风暴三叉戟拓扑处理 batches 元组数。
Transactional storm spout保证批不重叠,并且同一批始终包含同一组元组。
Opaque 风暴喷口保证批次不重叠,但批次内容可能会发生变化。
使用哪一个取决于您的系统需求和语义。

相关问题