Apache Kafka – Herramientas

La herramienta Kafka del paquete org.apache.kafka.tools. *. Las herramientas se clasifican en herramientas del sistema y herramientas de replicación.

Herramientas de sistema

Las herramientas del sistema se pueden ejecutar desde la línea de comandos mediante un script de inicio de clase. La sintaxis es la siguiente:

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

Algunas de las herramientas del sistema se mencionan a continuación:

  • Herramienta de migración de Kafka – Esta herramienta se utiliza para transferir un corredor de una versión a otra.

  • Fabricante de espejos – Esta herramienta se utiliza para proporcionar duplicación de un clúster de Kafka a otro.

  • Comprobación de créditos de consumo – Esta herramienta muestra el grupo de consumidores, el tema, las secciones, el desplazamiento, el tamaño de la revista, el propietario de un conjunto específico de temas y el grupo de consumidores.

Herramienta de replicación

La replicación de Kafka es una herramienta de diseño de alto nivel. El propósito de agregar una herramienta de replicación es mejorar la confiabilidad y la disponibilidad. Algunas de las herramientas de replicación se mencionan a continuación:

  • Herramienta de creación de temas – Esto crea un tema con un número predeterminado de particiones, una tasa de replicación y usa el esquema de Kafka predeterminado para asignar réplicas.

  • Herramienta de lista de temas – Esta herramienta muestra información sobre una lista determinada de temas. Si no se especifican temas en la línea de comando, la herramienta consulta a Zookeeper para obtener todos los temas y enumera información sobre ellos. Los campos que muestra la herramienta son nombre del tema, sección, líder, pistas, isr.

  • Herramienta Agregar sección – Al crear un tema, debe especificar el número de secciones del tema. En el futuro, el tema puede requerir secciones adicionales cuando aumente el volumen del tema. Esta herramienta le ayuda a agregar más particiones para un tema específico y también le permite asignar manualmente réplicas de las particiones agregadas.

🚫