我有一个kafka接收器连接器(elasticsearch(,我正在编写一个自定义SMT。我想知道如果SMT返回NULL
记录会发生什么。连接器的作用是什么?它会在我的弹性搜索索引中插入NULL
吗?还是根本不会插入?
您可以使用behavior.on.null.values
配置选项控制它的处理方式。
ignore
-消息被忽略delete
-具有匹配密钥的Elasticsearch记录被删除fail
-接头将停止
参考:文档页面