Как передавать сообщения от потребителя Kafka в приложение Django в новом контейнере docker?

Сервер Django застревает при запуске Kafka-comsumer. Что мне делать? Я хочу запустить этот потребитель как контейнер sidecar. Кто-нибудь может мне помочь?

consumer = KafkaConsumer("my-topic", bootstrap_servers=\['{}:{}'.format(HOST, PORT)\],auto_offset_reset="earliest", value_deserializer=lambda x: ReadHelper().json_deserializer(x), group_id="my_consumer_group" )
for msg in consumer:
print(msg)

Вернуться на верх