码迷,mamicode.com
首页 > 其他好文 > 详细

kafka sink partition

时间:2015-07-21 15:30:56      阅读:97      评论:0      收藏:0      [点我收藏+]

标签:

看如下代码段,kafka sink的key完全取决于上游发来的event中的header。所以,如果前面的source是像exec这样的source,由于其中的header为null,所以到了这就发到kafka中就是没key的。没key的情况下,kafka就做不了到不同broker的partition操作。

技术分享


kafka sink partition

标签:

原文地址:http://my.oschina.net/u/1421929/blog/481198

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!