Skip to content

qzibet/test_kafka

Repository files navigation

Для запуска нужен установить

poetry

python3.8

Установите все зависимости

poetry install

Войдите в вирт. окуржение

poetry shell

Запуск kafka

docker-compose up -d

Создать топик

kafka-topics --bootstrap-server broker:9092 \
             --create \
             --topic fibonacci

Читать сообщения

docker exec --interactive --tty broker kafka-console-consumer --bootstrap-server broker:9092                        --topic fibonacci                        --from-beginning

Запуск на python (записть)

python producer.py

Запуск на python (чтение)

python consumer.py

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages