KAFKACAT(1) | General Commands Manual | KAFKACAT(1) |
kafkacat
— generic
producer and consumer for Apache Kafka
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] |
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.
For a more extensive help and some simple examples, run
kafkacat
with -h
flag.
December 9, 2014 | Debian |