- kc-consume.sh
export BROKERS=mark.ang.com:9094 export USERNAME=user1 export PASSWORD=pwd1 export TOPIC=topic1 docker run -it --rm edenhill/kafkacat:1.5.0 -b $BROKERS -C \ -X security.protocol=SASL_PLAINTEXT \ -X sasl.mechanisms=SCRAM-SHA-256 \ -X sasl.username=$USERNAME \ -X sasl.password=$PASSWORD \ -t $TOPIC $*
usage
kc-consume.sh -c3 -obeginning -f%o--%p--%T--%k--%s\\n
producer mode
-P
listing meta data
-L
query mode. find offset by timestamp
-Q