mirror of
https://github.com/vimagick/dockerfiles.git
synced 2024-12-12 11:14:57 +02:00
31 lines
815 B
Markdown
31 lines
815 B
Markdown
kafka
|
|
=====
|
|
|
|
## How It Works
|
|
|
|
|
|
|
|
[read more](https://github.com/wurstmeister/kafka-docker/wiki/Connectivity)
|
|
|
|
## Up and Running
|
|
|
|
```bash
|
|
# 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 .
|
|
```
|
|
|
|
## Monitoring
|
|
|
|
https://telegraf-kafka.readthedocs.io/en/stable/index.html
|