• 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

Valid XHTML 1.0! Valid CSS! powered by MoniWiki
last modified 2021-06-08 21:57:03
Processing time 0.0050 sec