kafkacat1
Generic producer and consumer for apache kafka
Usage
kafkacat {-C | -P | -L
-t
topic
[-p
partition]
-b
brokers
[, ...]
[-D
delim]
[-K
delim]
[-c
cnt]
[-X
list]
[-X
prop=val]
[-X
dump]
[-d
dbg
[, ...]]
[-q]
[-v]
[-Z]
[specific
options]}
kafkacat -C
[generic
options]
[-o
offset]
[-e]
[-O]
[-u]
[-J]
[-f
fmtstr]
kafkacat -P
[generic
options]
[{-z
snappy | gzip}]
[-p
-1]
[file
[]]
kafkacat -L
[generic
options]
[-t
topic]
Overview
kafkacat is a generic non-JVM producer and consumer for Apache Kafka 0.8, think of it as a netcat for Kafka.
In producer mode ( -P ), kafkacat reads messages from stdin, delimited with a configurable delimeter and produces them to the provided Kafka cluster, topic and partition. In consumer mode ( -C ), kafkacat reads messages from a topic and partition and prints them to stdout using the configured message delimiter.
If neither -P or -C are specified kafkacat attempts to figure out the mode automatically based on stdin/stdout tty types.
kafkacat also features a metadata list mode ( -L ), to display the current state of the Kafka cluster and its topics and partitions.
Releases
Unchanged in 3 releases since Debian 9 (Stretch).