看以下代码段,kafka sink的key彻底取决于上游发来的event中的header。因此,若是前面的source是像exec这样的source,因为其中的header为null,因此到了这就发到kafka中就是没key的。没key的状况下,kafka就作不了到不一样broker的partition操做。 kafka