您可以通过定义 filter.condition .
链接中给出了一个示例，如下所示：

transforms=filterDateExample

# Use the 'io.confluent.connect.transforms.Filter$Value' as the source (record 'value') on which

# 'filter.condition' shall be applied.

transforms.filterDateExample.type=io.confluent.connect.transforms.Filter$Value
transforms.filterDateExample.filter.condition=$.key[?(@.date >= "2020-08-01" && @.date <= "2020-10-31")]

# Use 'include' to pass through all records that match the predicate.

transforms.filterDateExample.filter.type=include

# Use the 'fail' behavior to throw an exception and fail the connector task when the record does

# not have the field(s) used in the 'filter.condition'.

transforms.filterDateExample.missing.or.null.behavior=fail

它看起来无法识别日期类型，因此您可能还需要查看时间戳转换器。