kcat.md 1.1 KB

kcat

Productor Apache Kafka y herramienta de consumo. Más información: https://github.com/edenhill/kcat.

  • Consume mensajes empezando por el corrimiento (offset) más nuevo:

kcat -C -t {{tema}} -b {{intermediarios}}

  • Consume mensajes comenzando con el offset más antiguo y sale después de recibir el último mensaje:

kcat -C -t {{tema}} -b {{intermediarios}} -o beginning -e

  • Consume mensajes como grupo de consumidores de Kafka:

kcat -G {{id_de_grupo}} {{tema}} -b {{intermediarios}}

  • Publica el mensaje leyendo de stdin:

echo {{mensaje}} | kcat -P -t {{tema}} -b {{intermediarios}}

  • Publica mensajes leyendo desde un archivo:

kcat -P -t {{tema}} -b {{intermediarios}} {{ruta/al/archivo}}

  • Lista metadatos para todos los temas e intermediarios:

kcat -L -b {{intermediarios}}

  • Lista metadatos para un tema específico:

kcat -L -t {{tema}} -b {{intermediarios}}

  • Obtiene el offset de un tema/partición para un punto específico en el tiempo:

kcat -Q -t {{tema}}:{{partición}}:{{marca_de_tiempo_unix}} -b {{intermediarios}}