mirror of
https://github.com/tldr-pages/tldr.git
synced 2025-04-29 23:24:55 +02:00
37 lines
1.1 KiB
Markdown
37 lines
1.1 KiB
Markdown
![]() |
# 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}}`
|