dexblog.ro
Acces rapid: Învață AI Învață Programare Specificații Dispozitive Comparații
KAFKA Toate comenzile Apache Kafka

Sink Connector în Kafka Connect în Apache Kafka

Integrare: Kafka Connect & Schema Registry Kafka 0.9+ Q&A / Distribuie cod

Modul care consumă mesaje dintr-un topic Kafka și le scrie automat într-o destinație externă.

Sintaxă 
POST /connectors {"name": "destinatie-elastic", "config": {"connector.class": "..."}}

Ce face un Sink Connector

Un conector destinație (Sink Connector) citește evenimentele dintr-unul sau mai multe topice Kafka și le indexează sau stochează în depozite finale de date (Elasticsearch, Snowflake, Amazon S3, MongoDB, ClickHouse), gestionând automat confirmările de offset (commit) și lotizarea scrierilor.

Exemplu Concret: Indexarea evenimentelor în Elasticsearch
curl -X POST http://localhost:8083/connectors \
  -H "Content-Type: application/json" \
  -d '{
    "name": "elasticsearch-sink-orders",
    "config": {
      "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
      "tasks.max": "2",
      "topics": "comenzi-finalizate",
      "connection.url": "http://elasticsearch:9200",
      "type.name": "_doc",
      "key.ignore": "false",
      "schema.ignore": "true"
    }
  }'
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Sink Connector în Kafka Connect

Ai o nelămurire despre utilizarea comenzii Sink Connector în Kafka Connect sau 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.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.