特牛生活网

自定义Flume的Interceptor,编写、配置与使用-CSDN博客

网友收藏
基于需求,自己写了一个Flume的Interceptor,主要需求如下:kafka中数据格式为json字符串,需要利用Flume消费kafka中的数据,并按照指定的key的顺序,将value输出,并用指定分隔符分隔输入:String JsonString = "{'key1':'a','key2':'b','key3':'c','key4':'d','key5':'e','key6':'f'}...