在代理程序和重新平衡过程中出现异常时,NoAck 和手动确认不起作用

2020/06/02 00:12:47.173 INFO [di_cust_experience_conversation_processor.processors.conversation_processor] (print_stats) Rebalancing: False, Rebalances: 1, Events: 22, Messages: 22, Sent: 0, Messages/s 0 2020/06/02 00:12:47.173 INFO [di_cust_experience_conversation_processor.processors.conversation_processor] (print_stats) TP(topic='com.expedia.vap.Conversation.gcolab', partition=0), read:, , committed: , end:
2020/06/02 00:12:47.173 INFO [di_cust_experience_conversation_processor.processors.conversation_processor] (print_stats) TP(topic='com.expedia.vap.Conversation.gcolab', partition=1), read:, , committed: , end:
2020/06/02 00:12:47.173 INFO [di_cust_experience_conversation_processor.processors.conversation_processor] (print_stats) TP(topic='com.expedia.vap.Conversation.gcolab', partition=2), read:, , committed: , end:
2020/06/02 00:12:47.174 INFO [di_cust_experience_conversation_processor.processors.conversation_processor] (print_stats) …