Apache Flume Kafka Producer - 動態生成partition_id/key

Question

我有一個任務使用Apache Flume將消息發送到Kafka主題。需要注意的是，我必須根據消息中的IP地址指定一個分區。

有沒有辦法配置Apache Flume動態地執行此操作，還是必須實現自定義的Producer插件？

謝謝。

Answer 1

經過一番研究，配置製作人的唯一真正的自定義方式是自己推出。

我實現了AbstractSink接口，並把我自己的哈希算法生成一個分區來發送消息。