Implementación independiente de Kafka
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.