问题:org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1903520116 larger than 104857600)
分析:
在进行socket连接的时候,kafka报错,提示接收的字节数大于设置的最大字节数,1000M了。
可能是什么原因呢?
测试java socket连接
查找关于javasocket连接发送字节数的相关信息。
在测试过程中,原先我的java代码里有一行代码(原打算传入一个quit命令,关闭链接,不知道实际是否有用),去掉以后可以消除这个错误
out.write(“quit”.getBytes());
另外又发现了一个错误,同样是socket链接,会造成这个问题,待以后深入研究。
在这里插入图片描述

Logo

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

更多推荐