org.Apache.Kafka.clients.consumer.commitfailedexception 3360
Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member.
thismeansthatthetimebetweensubsequentcallstopoll (waslongerthantheconfiguredmax.poll.interval.ms，
whichtypicallyimpliesthatthepolloopisspendingtoomuchtimemessageprocessing。
youcanaddressthiseitherbyincreasingthesessiontimeoutorbyreducingthemaximumsizeofbatchesreturnedinpoll (with max.poll.rece ce
atorg.Apache.Kafka.clients.consumer.internals.consumer coordinator.sendoffsetcommitrequest (
atorg.Apache.Kafka.clients.consumer.internals.consumer coordinator.commitoffsetsync (consumer cooordinator.Java
atorg.Apache.Kafka.clients.consumer.Kafka consumer.commit sync (Kafka consumer.Java :1416 ) )。
atorg.Apache.Kafka.clients.consumer.Kafka consumer.commit sync (Kafka consumer.Java :1377 ) )。
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.ack immediate (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.processack (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.access $ 2600
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer $ consumerbatchacknowledgment.led
atcom.Gil data.three body.TBM.provider.Kafka.listener.kafkalistenerss.lambda $ batch listeners $0) Kafka listener
at Java.util.ArrayList.foreach (ArrayList.Java :1257 ) )。
atcom.Gil data.three body.TBM.provider.Kafka.listener.Kafka listeners.batch listener (
at sun.reflect.generatedmethodaccessor 816.invoke (unknown source ) )。
at sun.reflect.delegatingmethodaccessorimpl.invoke (delegatingmethodaccessorimpl.Java :43 ) atJava.lang.reflect
atorg.spring framework.messaging.handler.invocation.invocablehandlermethod.do invoke (invocablehandlermethod.Java
atorg.spring framework.messaging.handler.invocation.invocablehandlermethod.invocablehandlermethod.Java 3330
atorg.spring framework.Kafka.listener.adapter.handler adapter.invoke (handler adapter.Java 336048 ) )。
atorg.spring framework.Kafka.listener.adapter.messagingmessagelisteneradapter.invoke handler ()
atorg.spring framework.Kafka.listener.adapter.batchmessagingmessagelisteneradapter.on message (
atorg.spring framework.Kafka.listener.adapter.batchmessagingmessagelisteneradapter.on message (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.doinvokebatchlistener (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.invokebatchlistener (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.invoke listener (
atorg.spring framework.Kafka.listener.kafkamessagelistenercontainer $ listener consumer.run (at Java.util.concurrrer )
at Java.util.concurrent.future task.run (future task.Java :266 ) )。
at Java.lang.thread.run (thread.Java :748 ) )。