apache-kafka-connect

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

Вопрос или проблема Для последнего источника соединителя kafka-connect-cassandra (kafka-connect-cassandra-8.1.14 (или kafka-connect-cassandra-8.1.15.zip)), какая версия соответствует org.apache.kafka/connect-api? Последняя версия maven (3.

Вопрос или проблема Я пытаюсь записать тему Kafka (с данными proto!) в таблицу Postgres, используя Kafka-Connect и Schema-registry! Мой файл конфигурации соединителя Kafka-Connect: { "name":"proto_sink", "config":{ "connector.

Вопрос или проблема Я включил CDC в своем экземпляре Neo4j и настроил тему Kafka для прослушивания изменений данных в базе данных Neo4j. Согласно документации Neo4j, данные событий должны быть в формате пар “ключ-значение”