zookeeper no es una opción reconocida al ejecutar kafka-console-consumer.sh

2 minutos de lectura

avatar de usuario
xing bin

Estoy aprendiendo a usar Kafka en este sitio web Enlace(excepto que estoy usando el puerto 2182 en zookeeper), pero muestra:

zookeeper no es una opción reconocida

después de ejecutar:

sudo ./bin/kafka-console-consumer.sh –topic test –zookeeper localhost:2182

¿Como arreglarlo?

Env:

kafka_2.11-2.1.0
zookeeper-3.4.10

  • No necesita sudo para ejecutar estos comandos

    – Un jugador de críquet

    22 de noviembre de 2018 a las 17:47

avatar de usuario
xing bin

encuentro la respuesta en el INICIO RÁPIDO:

Opción zookeeper está en desuso, use --bootstrap-server en cambio.

Ahora funciona:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

  • último kafka usando bootstrap-server

    – Lova Chittumuri

    22 de noviembre de 2018 a las 12:41

  • Para crear uso de tema kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

    – Dhiraj

    13 de febrero a las 13:34

avatar de usuario
cerámica_negra_belleza

Para ventanas

Para iniciar zookeeper

C:\kafka-2.12>.\bin\windows\zookeeper-server-start.bat .\config\server.properties

Para iniciar Kafka Broker

C:\kafka-2.12>.\bin\windows\kafka-server-start.bat .\config\server.properties

Para crear tema

C:\kafka-2.12\bin\windows>kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Productor de inicio

C:\kafka-2.12\bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic test

Para crear consumidor

C:\kafka-2.12\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

Creación de temas Con partición múltiple con factor de replicación 1

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --topic first_topic --create --partitions 3 --replication-factor 1

Para obtener la lista de temas creados en el sistema

C:\kafka-2.12\bin\windows>kafka-topics --zookeeper localhost:2181 --list

Para obtener la descripción del tema creado en el sistema

C:\kafka-2.12\bin\windows>kafka-topics.bat --describe --zookeeper localhost:2181 --topic test

Para eliminar la prueba de tema creada en el sistema

C:\kafka-2.12\bin\windows>kafka-run-class.bat kafka.admin.TopicCommand --delete --topic test --zookeeper localhost:2181

Para leer el mensaje desde el comienzo de la prueba de tema creada en el sistema (versión> 2.0)

C:\kafka-2.12\bin\windows>kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginn

Para uso de usuarios de Windows

bin/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

  • elimine ‘bin’ y ejecute el comando desde la carpeta ‘bin/windows’.

    – madhu_karnati

    16 de enero de 2019 a las 1:47

ACTUALIZAR

  • A partir de la versión 2.1.* las respuestas anteriores pueden no funcionar, consulta siempre la oficial documentación esta respuesta proporcionada con la versión 3.1.0 .

Para sistemas base del kernel de Linux

./kafka-topics.sh --create --topic yourTopicname --bootstrap-server localhost:9092

Para sistemas Windows

./kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092

No hay necesidad de pasar --from-beginning cuando no hay compensación inicial y sobrecargar el comando de creación con deseado configuraciones

¿Ha sido útil esta solución?