Kafka Library 설치하기

pip3 install kafka-python

간단한 Producer, Consumer 만들기

Producer 만들기

producer.py

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers = ['localhost:9092'])

producer.send('test-topic', b'hello world!')
producer.flush()

Consumer 만들기

consumer.py

from kafka import KafkaConsumer

consumer = KafkaConsumer('test-topic', bootstrap_servers=['localhost:9092'])

for messages in consumer:
    print(messages)

실행하기

Consumer Python Script와 Producer Python Script를 실행하면 Message Record가 전달되는 것을 볼 수 있다.
value에 Message 값이 들어있다.

Producer Python Script를 또 한 번 실행하면 Message가 또 한 번 전달된다.