我有一个KafkaFlume连接器(elasticsearch),我正在编写一个自定义smt。我想知道如果smt返回 NULL 记录。连接器会做什么?它要插入什么东西吗 NULL 在我的elasticsearch索引中?还是根本就不会插入?
NULL
qf9go6mv1#
您可以使用 behavior.on.null.values 配置选项。 ignore -消息被忽略 delete -已删除具有匹配键的elasticsearch记录 fail -接头将停止。参考:文件页
behavior.on.null.values
ignore
delete
fail
1条答案
按热度按时间qf9go6mv1#
您可以使用
behavior.on.null.values
配置选项。ignore
-消息被忽略delete
-已删除具有匹配键的elasticsearch记录fail
-接头将停止。参考:文件页