A CLI tool for Kafka
[New Features]
[Fixes]
-gv
flags.[New Features]
produce plain
command now supports data templates to push randomly generated messages to Kafka.--sleep=Duration
parameter to produce
commands so that we can put a gap between publish operations.produce
commands now support --count=0
to allow publishing to Kafka indefinitely.[New Features]
oldest
, newest
, local
, etc) can be defined for individual partitions.consume
commands:
--to
: To define a stop offset/timestamp.--idle-timeout
: The amount of time the consumer will wait for a message to arrive before stop consuming from a partition.--exclusive
: Only explicitly defined partitions (Partition#Offset|Timestamp) will be consumed. The rest will be excluded.[Changes]
-U
(for SASL username) and -P
(for SASL password) short flags have been removed.Partition
and Key
metadata will be printed to the output as separate lines for non-json formats.UTC
suffix has been replaced with timezone offsets.--from
is now a repeatable flag instead of a single comma separated string.#
for --from
and --to
values.:Offset
) has been replaced with --exclusive
flag to reduce the complexity.topic
(or proto schema
) in the interactive mode, if it's already been provided via command arguments.[Fixes]
Change Log
list
output format has been replaced with tree
.--format json
)plain
output.-S, --include-timestamp
), partition key (-K, --include-partition-key
) and topic name (-T, --include-topic-name
) are injected into the Json output when consuming in json
and json-indent
mode.New Features
list
and json
output formats for administrative commands.--style
support for json
output.no-color
and no-colour
flags have the same effect.--format=plain
.Release Notes
Fixes
Release Notes
cmd
directoryRelease Notes
produce
commandsRelease Notes