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

v1uwarro  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(275)

我有一个KafkaFlume连接器(elasticsearch),我正在编写一个自定义smt。我想知道如果smt返回 NULL 记录。连接器会做什么?它要插入什么东西吗 NULL 在我的elasticsearch索引中?还是根本就不会插入?

qf9go6mv

qf9go6mv1#

您可以使用 behavior.on.null.values 配置选项。 ignore -消息被忽略 delete -已删除具有匹配键的elasticsearch记录 fail -接头将停止。
参考:文件页

相关问题