Kafka：生产者线程卡住了

问题描述

我有一个 Apache Nifi 工作流，可将数据流式传输到 Kafka。我的 Kafka 集群由 5 个使用 SSL 进行加密的节点组成。 当有大量数据要抛出时，我的 Kafka 生产者 (PublishKafkaRecord) 会冻结并停止工作。我必须重新启动处理器，但出现线程错误。 我使用的是 Kafka Confluent 5.3.1。

我在 Kafka 日志中看到这些错误：

ERROR Uncaught exception in scheduled task 'transactionalID-expiration' (Kafka.utils.Kafkascheduler)

retrying leaderEpoch request for partitions XXX-0 as the leader reported an error: UNKNowN_leader_EPOCH (kafka.server.ReplicaFetcherThread)

Could not find offset index file corresponding to log file XXX/*.log recovering segment and rebuilding index files (kafka.log.Log)

ERROR when handing request: .... __transaction_state

ERROR TransactionMetadata (... ) Failed: this should not happen (kafka.coordinator.transaction.TransactionMetadata)

我无法指出实际错误。

如何修复卡在 Kafka 中的线程？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）