flume+kafka實現根據消息的標識分配到不一樣的分區

需求html 在使用flume 收集 log的時候根據 不一樣的 消息表示多是uid。或者是日期。等關鍵字段 。 將消息發送到 kafka不一樣的分區 這裏就再也不貼詳細代碼 主要講一下本身的思路 。java 思路一： 自定義在flume攔截器中 使用 kafka producer 。直接將關鍵信息 獲取以後。根據邏輯。發送到不一樣的分區 。 主要實現如圖： git 配置文件修改： flume-c

>>阅读原文<<