Кафкой через kafka-python.
Подняв, стало быть, брокер-сервер из docker-compose от bitnami (вроде это стандартный способ завести себе песочницу-для-разработки).
Но у меня что-то даже хелло-ворлд не запускается: кажется, что брокер не замечает, что ему пытаются что-то передать.
https://github.com/Felix-neko/kafka_sandbox — вот, собрал мини-примерчик. Сможете глянуть, что у меня не так?
Чтобы запустить примерчик, надо клонировать его рекурсивно и вбить в трёх отдельных терминалах следующее
cd bitnami-docker-kafka && docker-compose up
python3 kafka_sandbox/start_consumer.py
python3 kafka_sandbox/start_producer.py
После этого в окошке start_consumer.py должно что-то напечататься, но у меня ничего не проходит. Как бы мне это забороть?
Естественно нет. Стандартный способ это Kafka-tutorials.confluent.io Берем нормальный композ https://kafka-tutorials.confluent.io/creating-first-apache-kafka-producer-application/kafka.html Берем примеры тут https://github.com/confluentinc/examples/tree/7.0.0-post/clients/cloud/python
Вот тут подробная объяснялка https://docs.confluent.io/platform/current/tutorials/examples/clients/docs/python.html
Обсуждают сегодня