使用水槽的kafka通道中的動態主題

Question

是否有可能擁有一個帶有動態主題的kafka通道 - 類似於可以指定主題頭的kafka水槽，或者可以使用頭中的值的HDFS水槽？

我知道我可以多路複用以使用多個通道（具有一堆通道配置），但這是不可取的，因爲我想有一個動態HDFS接收器，而不是每個kafka通道的HDFS接收器。

Answer 1

我的理解是Flume Kafka通道只能映射到單個主題，因爲它既生成又消耗特定主題的日誌。

查看Flume 1.6.0中的KafkaChannel.java中的代碼，我可以看到只有一個主題訂閱（每個線程有一個客戶）。