Creación de Tópicos, Productores y Consumidores
-
- Conectarse a Zoopeker:
- Para comprobar la conexión: bin/zkCli.sh -server localhost:2181
- Conectarse a kafka en segundo plano con daemon:
- Creación de nuevo topics:
- Visualización de los topics existentes:
- Para producir (pantalla de la izquieda) y consumir (pantalla de la derecha) mensajes desde shell (TEST).
Existen dos maneras de producir mensajes:
Esto quedará reflejado en el consumidor con un null o la clave.
- Para producir mensajes desde Spark Streaming (Scala):
- Para consumir mensajes desde Spark Streaming (Scala):
- Conectarse a Zoopeker: