Ce face un Source Connector
Un conector sursă (Source Connector) rulează în cadrul clusterului Kafka Connect și are misiunea de a monitoriza o sursă externă de date și de a trimite automat orice modificare (inserare, actualizare, ștergere) sub formă de evenimente într-un topic Kafka, fără ca dezvoltatorii să scrie cod manual de interogare.
Exemplu Concret: Capturarea modificărilor CDC cu Debezium PostgreSQL
curl -X POST http://localhost:8083/connectors \
-H "Content-Type: application/json" \
-d '{
"name": "postgres-cdc-orders",
"config": {
"connector.class": "io.debezium.connector.postgresql.PostgresConnector",
"tasks.max": "1",
"database.hostname": "db.internal",
"database.port": "5432",
"database.user": "debezium_user",
"database.password": "secret",
"database.dbname": "shop",
"database.server.name": "fulfillment",
"table.include.list": "public.orders"
}
}'
Întrebări & Exemple de Cod:
Source Connector în Kafka ConnectAi o nelămurire despre utilizarea comenzii
Source Connector în Kafka Connectsau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!
Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.