debezium

Вопрос или проблема У меня есть коннектор источника debezium postgres, который захватывает данные изменений в таблице, и я хотел бы отфильтровать строки, отправляемые в Kafka, на основе поля даты в таблице. Мне удалось отфильтровать по другим полям с