Druid 消費一個 kafka topic 發送到不同數據源

文章目錄 背景 解決辦法 一. 過濾標識在消息體中 二. 過濾標識在 header 中 源碼修改邏輯 背景 數據採集時，爲了避免在 kafka 中創建大量的 Topic ，採集時會將小的數據源寫入一個共享 Topic 中，以某個字段作爲標識。這裏有兩種方式： 直接將標識寫入消息體中 將標識寫入 record header 中 （kafka 0.11版本後支持） Druid 使用 druid-kaf

>>阅读原文<<