news 2026/7/1 23:58:44

kafka C++ 和 java端计算分区ID不一致排查

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
kafka C++ 和 java端计算分区ID不一致排查

生产端使用C++,将std:string key 传入,parititon设为-1,表示让kafka自动计算分区id
java端拿到反序列化后的key string,通过murmur2 算法计算出的分区id和kafka分配的分区id不一致

根本原因:C++的kafka使用CRC32 计算hash,Java端使用Murmur2

Key Difference: Hashing Algorithms
Java clients use the Murmur2 hash function by default.
C/C++ clients (which use the librdkafka library) use the CRC32 hash function by default.

只需要在java端也使用CRC32 计算key的hash就行了

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/30 10:55:22

【万金油-沟通管理】信息系统项目管理师案例分析

信息系统项目管理师案例分析【项目沟通管理万金油】内容,摘自:科科过纸质书《案例集分析》。1、沟通管理可能问题(1)规划沟通管理没进行规划沟通管理;沟通管理计划不能一人制订;沟通管理计划内容不全&#…

作者头像 李华