self-hosted/dockerfiles
1
0
Fork 0
mirror of https://github.com/vimagick/dockerfiles.git synced 2024-11-24 08:52:31 +02:00
Code Issues Releases Activity
369f66b075
dockerfiles/kafka
History
kev d45838ce06 update zookeeper
2019-09-26 19:41:55 +08:00
..
arm update superset 2018-07-28 10:51:01 +08:00
cluster update zookeeper 2019-09-26 19:41:55 +08:00
docker-compose.yml update kafka 2018-07-27 00:37:40 +08:00
README.md update kafka 2018-07-27 14:46:38 +08:00

README.md

kafka

How It Works

read more

Up and Running

# Broker
$ docker-compose up -d
$ docker-compose exec kafka bash
>>> kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 2 --topic my-topic
>>> kafka-topics.sh --alert --zookeeper zookeeper:2181 --topic my-topic --config retention.hours=168
>>> kafka-topics.sh --alert --zookeeper zookeeper:2181 --topic my-topic --delete-config retention.hours
>>> exit

# Producer
$ kafkacat -P -b localhost:9092 -t my-topic

# Consumer
$ kafkacat -C -b localhost:9092 -t my-topic -o end -u -q | jq .