mirror of https://github.com/CrimsonTome/tldr.git
37 lines
1.0 KiB
Markdown
37 lines
1.0 KiB
Markdown
|
# kcat
|
||
|
|
|
||
|
|
> Apache Kafka produceer en consumeer tool.
|
||
|
|
> Meer informatie: <https://github.com/edenhill/kcat>.
|
||
|
|
|
||
|
|
- Consumeer berichten startend met de nieuwste offset:
|
||
|
|
|
||
|
|
`kcat -C -t {{onderwerp}} -b {{makelaars}}`
|
||
|
|
|
||
|
|
- Consumeer berichten startend met de oudste offset en sluit af nadat het laatste bericht is ontvangen:
|
||
|
|
|
||
|
|
`kcat -C -t {{onderwerp}} -b {{makelaars}} -o beginning -e`
|
||
|
|
|
||
|
|
- Consumeer berichten als een Kafka consumeer groep:
|
||
|
|
|
||
|
|
`kcat -G {{groep_id}} {{onderwerp}} -b {{makelaars}}`
|
||
|
|
|
||
|
|
- Publiceer bericht via het lezen van de `stdin`:
|
||
|
|
|
||
|
|
`echo {{bericht}} | kcat -P -t {{onderwerp}} -b {{makelaars}}`
|
||
|
|
|
||
|
|
- Publiceer berichten via het lezen van een bestand:
|
||
|
|
|
||
|
|
`kcat -P -t {{onderwerp}} -b {{makelaars}} {{pad/naar/bestand}}`
|
||
|
|
|
||
|
|
- Toon de metadata voor alle onderwerpen en makelaars:
|
||
|
|
|
||
|
|
`kcat -L -b {{makelaars}}`
|
||
|
|
|
||
|
|
- Toon de metadata voor een specifiek onderwerp:
|
||
|
|
|
||
|
|
`kcat -L -t {{onderwerp}} -b {{makelaars}}`
|
||
|
|
|
||
|
|
- Verkrijg de offset voor een onderwerp/partitie voor een specifiek punt in de tijd:
|
||
|
|
|
||
|
|
`kcat -Q -t {{onderwerp}}:{{partitie}}:{{unix_timestamp}} -b {{makelaars}}`
|