Ce face comanda kafka-topics.sh –alter
Comanda kafka-topics.sh --alter permite extinderea capacității de procesare prin mărirea numărului de partiții pe un topic deja populat cu date. Acest lucru permite adăugarea mai multor instanțe de consumatori în grupul de procesare.
Exemplu Concret: Mărirea numărului de partiții de la 3 la 6
kafka-topics.sh --bootstrap-server localhost:9092 \
--alter \
--topic comenzi \
--partitions 6Atenționări critice la mărirea partițiilor
- Sens unic: În Kafka, numărul de partiții poate fi doar **mărit**, niciodată micșorat! Odată create, partițiile nu pot fi șterse individual.
- Afectarea cheilor de hash: Algoritmul implicit de partiționare calculează
murmur2(cheie) % num_partitions. La modificarea numărului de partiții, mesaje viitoare cu aceeași cheie vor ajunge pe partiții diferite, rupând ordinea strictă pe cheie între mesajele vechi și cele noi.
Întrebări & Exemple de Cod:
kafka-topics.sh –alter: Modificarea Partițiilor unui TopicAi o nelămurire despre utilizarea comenzii
kafka-topics.sh –alter: Modificarea Partițiilor unui Topicsau 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.