Przejdź do głównej zawartości

MongoDB Sink Connector

Target connector

MongoDB Sink Connector

MongoDB Sink zapisuje rekordy Kafka do kolekcji MongoDB.

KategoriaParametrWymaganyOpis
BasicnameTakUnikalna nazwa konektora docelowego.
Basicconnector.classTakKlasa MongoDB Sink dostępna w Kafka Connect.
Topicstopics / topics.regexTakTopiki Kafka konsumowane przez connector.
Connectionmongodb.connection.stringTakConnection string MongoDB target.
MappingdatabaseWarunkowoNazwa bazy docelowej, jeśli nie jest wyprowadzana z topiców.
MappingcollectionWarunkowoNazwa kolekcji docelowej, jeśli nie jest wyprowadzana z topiców.
Write modedelete.handling.modeNieSposób obsługi zdarzeń delete.
Runtimemax.batch.sizeNieRozmiar batcha zapisów.

Debezium MongoDB sink connector