我在追寻这个问题的答案用于kafka 2.3的spring在运行时使用kafkamessagelistenercontainer为特定侦听器设置偏移量如果我收到某个偏移量,我想停止容器。如何在“onmessage”中停止容器?另外,是否可以为容器设置初始偏移量?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!