* creating a topic<BR>

kafka-topics.sh --bootstrap-server localhost:9092 --create --topic firstTopic --partitions 1

<BR>* publishing a message<BR>

# using echo and jq to compact the message
echo '{"name": "hello world"}' | jq -c | kafka-console-producer.sh --bootstrap-server localhost:9092 --topic firstTopic
# from a file
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic firstTopic < message.json

<BR>* consuming a topic<BR>

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic firstTopic --from-beginning

<BR>* describing a event consumer<BR>

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group consumer_group_name --describe

<BR>* plan skip offset<BR>

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group consumer_group_name --topic topic_0 --reset-offsets --shift-by 1

<BR>* execute skip offset<BR>

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group consumer_group_name --topic topic_0 --reset-offsets --shift-by 1 --execute

<BR>* run kafka-ui<BR>

docker run -p 8080:8080 -e KAFKA_BROKERS=localhost:9092,192.168.0.1:9092 quay.io/cloudhut/kowl:master

all commands are tested on kafka 3.9.0