原文:org.apache.kafka.common.errors.SerializationException: Error deserializing... Caused by: org.apache.kafka.common.errors.SerializationException: Size of data received by IntegerDeserializer is not 4

原因,最近开发的kafka消息接收,突然报如下错: 原因如下,我的kafka序列化配置中配置的序列化类如下: 解决方法,将配置做如下修改: 问题解决。 ...

2020-07-09 11:20 0 1481 推荐指数:

查看详情

org.apache.kafka.common.network.Selector

org.apache.kafka.common.client.Selector实现了Selectable接口,用于提供符合Kafka网络通讯特点的异步的、非阻塞的、面向多个连接的网络I/O. 这些网络IO包括了连接的创建、断开,请求的发送和接收,以及一些网络相关的metrics统计等功能 ...

Mon Jul 25 07:58:00 CST 2016 0 2888
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM