Apache Kafka - Strumenti

Strumento Kafka contenuto in "org.apache.kafka.tools. *. Gli strumenti sono classificati in strumenti di sistema e strumenti di replica.

Strumenti di sistema

Gli strumenti di sistema possono essere eseguiti dalla riga di comando utilizzando lo script della classe di esecuzione. La sintassi è la seguente:

bin/kafka-run-class.sh package.class - - options

Alcuni degli strumenti di sistema sono menzionati di seguito:

  • Kafka Migration Tool - Questo strumento viene utilizzato per migrare un broker da una versione all'altra.

  • Mirror Maker - Questo strumento viene utilizzato per fornire il mirroring di un cluster Kafka a un altro.

  • Consumer Offset Checker - Questo strumento visualizza il gruppo di consumatori, l'argomento, le partizioni, l'off-set, la dimensione del registro, il proprietario per il set di argomenti e il gruppo di consumatori specificato.

Strumento di replica

La replica di Kafka è uno strumento di progettazione di alto livello. Lo scopo dell'aggiunta di uno strumento di replica è per una maggiore durata e una maggiore disponibilità. Alcuni degli strumenti di replica sono menzionati di seguito:

  • Create Topic Tool - Questo crea un argomento con un numero predefinito di partizioni, fattore di replica e utilizza lo schema predefinito di Kafka per eseguire l'assegnazione delle repliche.

  • List Topic Tool- Questo strumento elenca le informazioni per un determinato elenco di argomenti. Se non vengono forniti argomenti nella riga di comando, lo strumento interroga Zookeeper per ottenere tutti gli argomenti ed elenca le informazioni per essi. I campi visualizzati dallo strumento sono nome argomento, partizione, leader, repliche, isr.

  • Add Partition Tool- Creazione di un argomento, è necessario specificare il numero di partizioni per argomento. Successivamente, potrebbero essere necessarie più partizioni per l'argomento, quando il volume dell'argomento aumenterà. Questo strumento aiuta ad aggiungere più partizioni per un argomento specifico e consente anche l'assegnazione manuale della replica delle partizioni aggiunte.