[kcat usage with authentication] How to use kcat as producer / consumer and provide credentials #kafka #aws

kcat.sh

# Metadata listing mode
kcat -L \
-b $KAFKA_BROKER:9096 \
-X security.protocol=SASL_SSL \
-X sasl.mechanisms=SCRAM-SHA-512 \
-X sasl.username=$USERNAME \
-X sasl.password=$PASSWORD

# Producer mode
kcat -t $KAFKA_TOPIC -P \
-b $KAFKA_BROKER:9096 \
-X security.protocol=SASL_SSL \
-X sasl.mechanisms=SCRAM-SHA-512 \
-X sasl.username=$USERNAME \
-X sasl.password=$PASSWORD

# Consumer mode
kcat -t $KAFKA_TOPIC \
-b $KAFKA_BROKER:9096 \
-f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
-X security.protocol=SASL_SSL \
-X sasl.mechanisms=SCRAM-SHA-512 \
-X sasl.username=$USERNAME \
-X sasl.password=$PASSWORD