SYNOPSIS

-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]
-C [generic options] [-o offset ] [-e ] [-O ] [-u ] [-J ] [-f fmtstr ]
-P [generic options] [-z snappy | gzip ] [-p -1 ] [file [...] ]
-L [generic options] [-t topic ]

DESCRIPTION

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 ), reads messages from stdin, delimited with a configurable delimeter and produces them to the provided Kafka cluster, topic and partition. In consumer mode ( -C ), reads messages from a topic and partition and prints them to stdout using the configured message delimiter.

If neither -P or -C are specified attempts to figure out the mode automatically based on stdin/stdout tty types.

also features a metadata list mode ( -L ), to display the current state of the Kafka cluster and its topics and partitions.