看以下代碼段,kafka sink的key徹底取決於上游發來的event中的header。因此,若是前面的source是像exec這樣的source,因爲其中的header爲null,因此到了這就發到kafka中就是沒key的。沒key的狀況下,kafka就作不了到不一樣broker的partition操做。 kafka