Red de conocimiento informático - Aprendizaje de programación - Implementación independiente de Kafka

Implementación independiente de Kafka

La instalación de Kafka requiere zookeeper, pero kafka integra zookeeper y puede usarse directamente para una implementación independiente. Simplemente configure zookeeper.preperties en Kafka_2.11.x/config.

tar -xvfkafka_2.11-2.3.0.tgz

Modifica dos elementos de configuración, dataDir y clientPort. La primera es la dirección de almacenamiento de la instantánea y la segunda es el puerto a través del cual el cliente se conecta al servicio zookeeper.

Rellénelo según su situación real, o puede utilizar el valor predeterminado directamente.

Modifique dos opciones de configuración, log.dirs y zookeeper.connect

Log.dirs se puede completar de acuerdo con la situación real o se puede usar directamente el valor predeterminado.

Zookeeper.connect debe ser coherente con clientPort en el archivo zookeeper.preperties.

Una vez completadas las operaciones anteriores, se completa la implementación independiente.

Norhop. /zookeeper-server-start.sh ../config/zookeeper . properties & gt; ../zookeeper log &

Inicie zookeeper en segundo plano y escriba el registro de inicio en zookeeper.log

p>

Verifique zookeeper.log después del inicio para ver si zookeeper se inició correctamente.

Norhop. /kafka-server-start.sh ../config/server properties & gt; ../kafka. & amp

Kafkaserver se inicia en segundo plano y el registro de inicio se escribe en kafka.log< / p>

Verifique kafka.log después del inicio para ver si el inicio fue exitoso.

. /Kafka-topics sh-create-zookeeper IP:2291-factor de replicación 1-particiones 1-tema prueba & /Kafka-console-producer .sh-broker-list IP:9092-tema prueba & /Kafka-console-consumer .sh-bootstrap-server IP:2291-topic test-from scratch

Métodos para comprobar si los productores y consumidores son normales:

Productores y consumidores Cada uno de ellos abren una terminal y ejecutan comandos para crear productores y consumidores respectivamente. Después de ejecutar el comando del productor, envían un mensaje: kafkatest El terminal del consumidor puede recibir este mensaje, lo cual es normal.