综合

kafka sink partition

导读: 

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

技术分享


相关资讯

发表评论
网友评论0 条评论)
暂无评论