- 链接地址:https://blog.csdn.net/weixin_42102379/article/details/83590559
- 链接标题:自定义Flume的Interceptor,编写、配置与使用-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:212
基于需求,自己写了一个Flume的Interceptor,主要需求如下:kafka中数据格式为json字符串,需要利用Flume消费kafka中的数据,并按照指定的key的顺序,将value输出,并用指定分隔符分隔输入:String JsonString = "{'key1':'a','key2':'b','key3':'c','key4':'d','key5':'e','key6':'f'}...
版权声明:本文发布于特牛生活网 内容均来源于互联网 如有侵权联系删除