Caused by: org.apache.kafka.common.KafkaException: Received exception when fetching the next record from t_vpn-2. If needed, please seek past the record to continue consumption.

Caused by: org.apache.kafka.common.KafkaException: Record batch for partition t_vpn-2 at offset 676544393 is invalid, cause: Record is corrupt (stored crc = 2998702025, computed crc = 1639670923)

有人说是kafka未消费到消息, 消息就过期了, 也有人说是防火墙未关闭, 我这次问题实际上是网络问题, 重启网卡, 问题解决

Logo

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

更多推荐