当前位置:网站首页>Flume series: interceptor filtering data
Flume series: interceptor filtering data
2022-07-05 19:50:00 【Target Blogger】
flume Series of : Interceptor filter data
One 、kafka Null data
ConsumerRecord(topic=‘debezium-prod-optics_prod_1h.optics_prod.user_order’, partition=2, offset=3636705, timestamp=1656746091521, timestamp_type=0, key=b’{“schema”:{“type”:“struct”,“fields”:[{“type”:“int32”,“optional”:false,“field”:“order_id”}],“optional”:false,“name”:“debezium_prod_optics_prod_1h.order_prod.user_order.Key”},“playload”:{“order_id”:2752094}}', value=None, headers=[], checksum=None, serialized_key_size=223, serialized_value_size=-1, serialized_header_size=-1)
As shown above :
- value=None
- flume You can use interceptors to filter out value by None Of kafka news
Two 、 Interceptors filter null data
For more interceptor related blogs, please refer to the blogger's next two articles :
边栏推荐
- MMO project learning 1: preheating
- Postman core function analysis - parameterization and test report
- 建立自己的网站(16)
- Is it safe for Guosen Securities to open an account online?
- ACM getting started Day1
- Relationship between floating elements and parent and brother boxes
- 从零实现深度学习框架——LSTM从理论到实战【实战】
- okcc呼叫中心有什么作用
- 成功入职百度月薪35K,2022Android开发面试解答
- 四万字长文说operator new & operator delete
猜你喜欢
如何安全快速地从 Centos迁移到openEuler
司空见惯 - 英雄扫雷鼠
webuploader文件上传 拖拽上传 进度监听 类型控制 上传结果监听控件
全网最全的低代码/无代码平台盘点:简道云、伙伴云、明道云、轻流、速融云、集简云、Treelab、钉钉·宜搭、腾讯云·微搭、智能云·爱速搭、百数云
Bitcoinwin (BCW) was invited to attend Hanoi traders fair 2022
力扣 729. 我的日程安排表 I
[OBS] qstring's UTF-8 Chinese conversion to blog printing UTF-8 char*
Android interview, Android audio and video development
Android面试,android音视频开发
成功入职百度月薪35K,2022Android开发面试解答
随机推荐
C - sequential structure
Common operators and operator priority
Necessary skills for interview in large factories, 2022android will not die, I will not fall
不愧是大佬,字节大牛耗时八个月又一力作
How to safely and quickly migrate from CentOS to openeuler
建立自己的网站(16)
What does software testing do? What are the requirements for learning?
Reinforcement learning - learning notes 4 | actor critical
集合
webuploader文件上传 拖拽上传 进度监听 类型控制 上传结果监听控件
Summer Challenge database Xueba notes, quick review of exams / interviews~
Add data to excel small and medium-sized cases through poi
手机股票开户安全吗?靠不靠谱啊?
爬虫练习题(二)
[untitled]
The city chain technology Digital Innovation Strategy Summit was successfully held
Do you know several assertion methods commonly used by JMeter?
安信证券在网上开户安全吗?
Reptile exercises (II)
Apprentissage du projet MMO I: préchauffage