github.com/deviceinsight/kafkactl

Added

• #110 Added protobuf support to consume/produce commands (@xakep666 thank you for the contribution)

Fixed

• fixed parsing of --replicas flag for alter partition when running against kubernetes cluster

Added

• Add new command describe broker to view broker configurations

Fixed

• #106 Do not check if topic is available before produce, because otherwise autoTopicCreation does not work

• fix brew warning (https://github.com/goreleaser/goreleaser/pull/2591)

Added

• Added parameter --null-value to produce command in order to produce a null value (tombstone)

Added

• Added new command delete consumer-group-offset to delete a consumer-group-offset
• Add new command get brokers to get the list of brokers advertised by Kafka

Fixed

• SASL mechanism setting is now supported in kafkactl attach

Fixed

• Filter -C and --config-file option in kubernetes context

Added

• Support delete command when accessing a remote cluster deployed on kubernetes

Added

• Added new commands delete consumer-group to delete a consumer-group

Fixed

• Calls to the AVRO schema registry are now cached correctly

Fixed

• alter topic should fail, when trying to set number of partitions to the current number of partitions

Changed

• the default for required-acks in the producer has been changed to WaitForLocal in order to align with the JVM Producer. In addition, this setting is now also configurable.

Fixed

• fix version prefix in aur package. kubernetes support not working without the prefix.

Fixed

• Compatibility with new versions of kubectl by removing deprecated parameter from the command
• Replace CMD with ENTRYPOINT in Ubuntu Dockerfile to restore behavior documented in readme

Fixed

• SASL mechanism support now also implemented for cluster admin
• process no longer gets stuck when deserialization error occurs

Added

• calls to avro schema registry are now cached in memory to improve performance

Changed

• Updated avro library to latest version (v2.10.0)

Added

• Introduce configuration options to configure sasl.mechanism in order to use scram-sha512 or scram-sha256 instead of plaintext.
• Added new commands get acl, create acl, delete acl to manage Kafka ACLs with kafkactl

Fixed

• Fixed Ctrl+C not working to stop kafkactl

Added

• Add parameter --skip-empty to describe topic command which allows skipping/hiding empty partitions.

Changed

• describe topic now includes EMPTY field, which directly shows if a partition contains messages.

Added

• Add parameter --replication-factor to alter topic command which allows changing the replication factor of a topic. Note that kafka >= 2.4.0.0 is required, otherwise the relevant api calls are not available.
• Added command alter partition which currently only enables to manually assign broker replicas to a partition. Note that kafka >= 2.4.0.0 is required, otherwise the relevant api calls are not available.
• Added requestTimeout config to control timeout of admin requests.

Fixed

• Add certificates to TlsConfig when tls.insecure = true

Fixed

• get consumer-groups -o compact --topic=xyz no longer ignores the topic parameter

Added

• Ubuntu Docker image has CA certificates installed.
• Scratch Docker image has CA certificates installed.

Changed

• get consumer-groups now includes the assigned topics as long as output format is not compact.

Changed

• TLS configuration now starts off with the System's CA pool instead of a completely empty one. This improves support for AWS MSK with PCAs.

Added

• direct support for kafka clusters running in kubernetes
• attach command to get a bash into kafkactl pod when running in kubernetes

Added

• direct support for kafka clusters running in kubernetes
• attach command to get a bash into kafkactl pod when running in kubernetes

Fixed

• auto-completion should now work consistent for all supported shells and provides dynamic completion for e.g. names of topics or consumer-groups.

Added

• Add parameters --key-encoding, --value-encoding to produce command to write messages from hex/base64
• Add parameters --key-encoding, --value-encoding to consume command to print messages as hex/base64
• auto-completion now also works inside ubuntu docker image
• bash auto-completion should work out of the box, when kafkactl is installed via snap

Changed

• improved and documented overriding config keys via environment variables
• Binary (non-string) messages are auto-detected and printed as base64 by default

Added

• Add parameter --header to produce command to include message headers when writing messages

Changed

• generation of commands and error handling have been refactored in order to allow for better testability
• dockerfile is build from UBUNTU:LATEST instead of SCRATCH

Fixed

• loading custom CA cert failed in 1.8.0