如何使用flume根据kafka消息中的消息类型写入自定义hdfs目录？说出Kafka的信息： {"type": "A", "data": "blah"} 在类型字段中有“a”应该写入 /data/A ，消息： {"type": "B", "data": "blah"} 在类型字段中有“b”应写入 /data/B 等等
{"type": "A", "data": "blah"}
/data/A
{"type": "B", "data": "blah"}
/data/B
hfyxw5xn1#
我想你需要定制FlumeFlume。apacheFlume定制Flume
1条答案
按热度按时间hfyxw5xn1#
我想你需要定制FlumeFlume。apacheFlume定制Flume