$ kt -help
kt is a tool for Kafka.
Usage:
kt command [arguments]
The commands are:
consume consume messages.
produce produce messages.
topic topic information.
group consumer group information and modification.
admin basic cluster administration.
Use "kt [command] -help" for for information about the command.
Authentication:
Authentication with Kafka can be configured via a JSON file.
You can set the file name via an "-auth" flag to each command or
set it via the environment variable KT_AUTH.
Authentication / Encryption
Authentication configuration is possibly via a JSON file. You indicate the mode
of authentication you need and provide additional information as required for
your mode. You pass the path to your configuration file via the -auth flag to
each command individually, or set it via the environment variable KT_AUTH.
TLS
Required fields:
mode: This needs to be set to TLS
client-certificate: Path to your certificate
client-certificate-key: Path to your certificate key
ca-certificate: Path to your CA certificate
Example for an authorization configuration that is used for the system tests:
If any certificate or key path is simply the name of the file, it is assumed to
be in the same directory as the auth file itself. For example if the path to the
auth file is /some/dir/kt-auth.json then a "client-certificate": "kt-test.crt" will be qualified to /some/dir/kt-test.crt.
TLS one-way
Required fields:
mode: This needs to be set to TLS-1way
Optional fields:
ca-certificate: Path to your CA certificate
Example:
{
"mode": "TLS-1way"
}
Other modes
Please create an
issue with details for the mode that you need.