如果转换返回NULL,kafka接收器连接器是否插入记录



我有一个kafka接收器连接器(elasticsearch(,我正在编写一个自定义SMT。我想知道如果SMT返回NULL记录会发生什么。连接器的作用是什么?它会在我的弹性搜索索引中插入NULL吗?还是根本不会插入?

您可以使用behavior.on.null.values配置选项控制它的处理方式。

  • ignore-消息被忽略
  • delete-具有匹配密钥的Elasticsearch记录被删除
  • fail-接头将停止

参考:文档页面

最新更新