kafka相关配置问题
2016-03-14 18:54
211 查看
# message encoder
serializer.class=kafka.serializer.StringEncoder
决定了 你的Producer 的声明
如果kafka.serializer.StringEncoder
则：
inner = new Producer<String, String>(config);
如果是kafka.serializer.DefaultEncoder
则：
inner = new Producer<String, byte>(config);
今天搭建kafka 遇到的一点编码相关问题
serializer.class=kafka.serializer.StringEncoder
决定了 你的Producer 的声明
如果kafka.serializer.StringEncoder
则：
inner = new Producer<String, String>(config);
如果是kafka.serializer.DefaultEncoder
则：
inner = new Producer<String, byte>(config);
今天搭建kafka 遇到的一点编码相关问题
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- YTU: 字符串长度
- 数论系列之欧几里得
- 1439: 2.4.5 Fractions to Decimals 分数化小数
- Lua面向对象程序设计
- android dialog设置宽高之后界面显示不全问题
- hdu 2136 Largest prime factor
- css属性选择器应用
- 课堂所讲整理：输入输出流（I/O）2（修改版）
- Java值传递和引用传递详细解说
- python爬虫被封异常处理
- 02Windows下解决adb连接不上的终极解决方案
- 经典_STM32_ADC多通道采样的例子
- C++11 之for 新解
- 《与小卡特一起学Python》Code3 抓取网页中的某个数据
- JavaAPI之Runtime类以及bat文件开启应用程序
- 文件加锁
- CocoaPods详解之----进阶篇
- codeforces 10 D. LCIS LCIS O(n^2)算法
- hdoj-2086-A1=?
- 对于软件工程的理解