kafka-topics.sh –create: Crearea Topicelor în Apache Kafka în Apache Kafka

Comanda CLI oficială pentru inițializarea topicelor noi pe clusterul Kafka, specificând numărul de partiții și factorul de replicare.

Sintaxă
kafka-topics.sh --bootstrap-server <host:port> --create --topic <nume> --partitions <nr> --replication-factor <nr>

Ce face comanda kafka-topics.sh –create

Comanda kafka-topics.sh --create este utilizată de inginerii DevOps și dezvoltatori pentru a declara un topic nou într-un cluster Apache Kafka. Aceasta configurează de la început partiționarea (care controlează scalabilitatea și paralelismul consumatorilor) și factorul de replicare (care asigură toleranța la căderi hardware).

Exemplu Concret: Crearea unui topic de plăți cu 6 partiții și replicare 3
kafka-topics.sh --bootstrap-server localhost:9092 \
  --create \
  --topic tranzactii-plati \
  --partitions 6 \
  --replication-factor 3 \
  --config min.insync.replicas=2 \
  --config retention.ms=604800000

Parametri importanți

  • --bootstrap-server: Adresa unuia sau mai multor brokeri din cluster (ex: broker1:9092,broker2:9092).
  • --partitions: Numărul de fluxuri paralele în care sunt distribuite mesajele topicului.
  • --replication-factor: Câte copii ale fiecărei partiții sunt menținute pe brokeri diferiți. Nu poate depăși numărul total de brokeri disponibili.
  • --config: Permite suprascrierea configurațiilor implicite (retenție, compactare, min.insync.replicas) direct la momentul creării.
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: kafka-topics.sh –create: Crearea Topicelor în Apache Kafka

Ai o nelămurire despre utilizarea comenzii kafka-topics.sh –create: Crearea Topicelor în Apache Kafka 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.