/
LarsFillmore
/
python_basic-flask-kafka
Обзор
Документация
Войти
/
LarsFillmore
/
python_basic-flask-kafka
Код
Запросы
0
Задачи
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
python-client/main.py
30 строк
771 B
SoullessSoldier
init
29 авг 2024, 00:46
29 авг 2024, 00:46
9206f4d
Код
Авторство
О чём код?
from kafka import KafkaProducer, KafkaConsumer from time import sleep def send_message_to_kafka(): producer = KafkaProducer(bootstrap_servers=['localhost:9094']) for i in range(1,100): my_str = f'my {str(i).zfill(3)} message from python' producer.send( topic='messages', value=my_str.encode(), key=b'python-message', ) sleep(1) def get_message_from_kafka(): consumer = KafkaConsumer( 'messages', bootstrap_servers=['localhost:9094'], auto_offset_reset='earliest', group_id='echo-messages-to-stdout', ) for message in consumer: print(message.value) if __name__ == '__main__': send_message_to_kafka() get_message_from_kafka()