【发布时间】:2021-03-18 03:33:20
【问题描述】:
我是 Kafka 新手,我使用 Kafka 和 Camunda 设计了一个流程,以在线性流程中执行多个短操作。我需要了解哪种 ackMode 最适合我的 Listener - Batch 或 Record。哪个更适合超时场景?哪个更适合错误处理?
【问题讨论】:
标签: apache-kafka workflow spring-kafka camunda
我是 Kafka 新手,我使用 Kafka 和 Camunda 设计了一个流程,以在线性流程中执行多个短操作。我需要了解哪种 ackMode 最适合我的 Listener - Batch 或 Record。哪个更适合超时场景?哪个更适合错误处理?
【问题讨论】:
标签: apache-kafka workflow spring-kafka camunda
当我们轮询消费者时,我们会得到多条记录。
使用 RECORD 模式,在处理完每条记录后提交偏移量。
使用 BATCH 模式,在处理完批处理中的所有记录后,将全部提交偏移量。
这是客户端/代理之间的 I/O 与系统崩溃后接收重复交付的可能性之间的权衡。
【讨论】: