背景:公司要使用华为云的kafka服务,我负责进行技术预研,后期要封装kafka组件。

从华为云下载了demo,完全按照开发者文档来进行配置文件配置,但是会报以下错误。

org.apache.kafka.common.errors.TimeoutException: Expiring 10 record(s) for topic-0: 30015 ms has passed since batch creation plus linger time

网上大部分给与的解决方向是检查应用服务与kafka的集群的通信是否畅通。

我在本地ping kafka的3个broker都是通的。

后来经过了一轮debug去挖错误出现的具体位置,挖了半天挖不倒头。

后来尝试打包挪动到我的腾讯云服务器上进行实验。

在实验之前,我把公司的wife切换成了手机热点实验了一下。成了。

我X,公司的网络安全策略惹得锅。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐