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}}