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.
Întrebări & Exemple de Cod:
kafka-topics.sh –create: Crearea Topicelor în Apache KafkaAi o nelămurire despre utilizarea comenzii
kafka-topics.sh –create: Crearea Topicelor în Apache Kafkasau 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.