kafkactl consume
Consume messages from a topic
Options
| Name | Description |
|---|---|
--exit, -e | Stop consuming when latest offset is reached |
--from-beginning, -b | Set offset for consumer to the oldest offset |
--group, -g <group> | Consumer group to join |
--key-encoding <key-encoding> | Key encoding (auto-detected by default). One of: none|hex|base64 |
--key-proto-type <key-proto-type> | Key protobuf message type |
--max-messages <max-messages> | Stop consuming after n messages have been read |
--offset <offset> |
|
--output, -o <output> | Output format. One of: json|yaml |
--partitions, -p <partitions> |
|
--print-headers | Print message headers |
--print-keys, -k | Print message keys |
--print-schema, -a | Print details about avro schema used for decoding |
--print-timestamps, -t | Print message timestamps |
--proto-file <proto-file> |
|
--proto-import-path <proto-import-path> |
|
--protoset-file <protoset-file> |
|
--separator, -s <separator> | Separator to split key and value |
--tail <tail> | Show only the last n messages on the topic |
--value-encoding <value-encoding> | Value encoding (auto-detected by default). One of: none|hex|base64 |
--value-proto-type <value-proto-type> | Value protobuf message type |