错误异常信息

o.s.k.core.DefaultKafkaProducerFactory :Abort failed: CloseSafeProducer [delegate=org.apache.kafka.clients.producer.KafkaProducer@7599cba3]

org.apache.kafka.common.KafkaException: Cannot execute transactional method because we are in an error state

at org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:1010)

at org.apache.kafka.clients.producer.internals.TransactionManager.lambda$beginAbort$3(TransactionManager.java:268)

at org.apache.kafka.clients.producer.internals.TransactionManager.handleCachedTransactionRequestResult(TransactionManager.java:1116)

at org.apache.kafka.clients.producer.internals.TransactionManager.beginAbort(TransactionManager.java:266)

错误原因

Caused by: org.apache.kafka.common.errors.UnsupportedVersionException: Broker doesn't support group metadata commit API on version 2, minimum supported request version is 3 which requires brokers to be on version 2.5 or above.

解决办法2023-12-01 15:09:30.453 主要是版本不支持！kafka-server端更新最新的版本就可以的，起码2.5以上版本

本站仅提供存储服务，所有内容均由用户发布，如发现有害或侵权内容，请点击举报。