docker-compose up -d

./start-kafka-single-node.sh

docker run --rm -i --network=host confluentinc/cp-kafka:5.2.4 /usr/bin/kafka-topics \
	--create \
	--bootstrap-server localhost:9092 \
	--replication-factor 3 \
	--partitions 4 \
	--config retention.ms=60000 \
	--topic the-topic

docker run --rm -i --network=host edenhill/kcat:1.7.0 -L -b localhost:9092

docker run --rm -it --network=host edenhill/kcat:1.7.0 -C -f 'partition=%p offset=%o >> key=%k value=%s\n' -b "localhost:9092" -t "the-topic"

docker run --rm -it --network=host edenhill/kcat:1.7.0 -b "localhost:9092" -f "topic=%t >> partition=%p offset=%o >> key=%k value=%s\n" -G consumer topicA topicB topicC

echo "key:value" | docker run --rm -i --network=host edenhill/kcat:1.7.0 -X topic.partitioner=murmur2_random -P -b localhost:9092 -t the-topic -Z -K:

echo key:'{"uid":"'$(uuidgen)'", "message":"hello"}' | docker run --rm -i --network=host edenhill/kcat:1.7.0 -P -X topic.partitioner=murmur2_random -b localhost:9092 -t the-topic -K:

docker run --rm -i --network=host confluentinc/cp-kafka:5.2.4 /usr/bin/kafka-topics \
	--delete \
	--bootstrap-server localhost:9092 \
	--topic the-topic

docker-compose stop

docker-compose down