Apache Kafka - Narzędzia
Narzędzie Kafka spakowane pod adresem „org.apache.kafka.tools. *. Narzędzia są podzielone na narzędzia systemowe i narzędzia do replikacji.
Narzędzia systemowe
Narzędzia systemowe można uruchamiać z wiersza poleceń za pomocą skryptu klasy uruchamiania. Składnia jest następująca -
bin/kafka-run-class.sh package.class - - optionsNiektóre z narzędzi systemowych są wymienione poniżej -
Kafka Migration Tool - To narzędzie służy do migracji brokera z jednej wersji do drugiej.
Mirror Maker - To narzędzie służy do tworzenia kopii lustrzanych jednego klastra Kafka w innym.
Consumer Offset Checker - To narzędzie wyświetla grupę konsumentów, temat, partycje, przesunięcie, rozmiar dziennika, właściciel dla określonego zestawu tematów i grupę konsumentów.
Narzędzie replikacji
Replikacja Kafki to narzędzie do projektowania wysokiego poziomu. Celem dodania narzędzia do replikacji jest większa trwałość i wyższa dostępność. Niektóre z narzędzi do replikacji są wymienione poniżej -
Create Topic Tool - Tworzy temat z domyślną liczbą partycji, współczynnikiem replikacji i używa domyślnego schematu Kafki do przypisywania replik.
List Topic Tool- To narzędzie wyświetla informacje dla danej listy tematów. Jeśli w wierszu poleceń nie podano żadnych tematów, narzędzie wysyła zapytanie do Zookeepera, aby uzyskać wszystkie tematy i wyświetla ich informacje. Pola wyświetlane przez narzędzie to nazwa tematu, partycja, lider, repliki, isr.
Add Partition Tool- Tworzenie tematu, należy określić liczbę podziałów na temat. Później może być potrzebnych więcej partycji dla tematu, gdy objętość tematu wzrośnie. To narzędzie pomaga dodawać więcej partycji dla określonego tematu, a także umożliwia ręczne przypisywanie dodanych partycji replik.