我将数据发送到具有多个分区的kafka主题。
例如，有10个分区的主题，我想基于分区（在多个hdfs目录中）将数据保存在hdfs路径中。
例如，我的hdfs路径目录应该是：/topicname/partition1、/topicname/partition2等。。
我正在使用kafka频道-org.apache.flume.channel.kafka.kafkachannel。