标签:
看如下代码段,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