consume

var Consume = &charm.Spec{
	Name:  "consume",
	Usage: "consume [options]",
	Short: "consume data from a Kafka topic and format as Zed output",
	Long: `
The consume command reads Avro records from a Kafka topic.

Consume reads each record as Avro and transcodes it to Zed using the configured
schema registry.  Any of the output formats used by the "zed" command may be
specified in the same way as in the zed query commands (i.e., zq, zed query, etc).

Once consume reaches the head of the Kafka topic, it blocks and waits for more
data and gives up and exits if a timeout is provided.  Note that if the duration
is too short, consume may exit before any available records are ready
asynchronously from the topic.
`,
	New: New,
}