지난 포스팅에서 kafka 토픽 생성/조회를 python 으로 해봤습니다. 이젠 메시지를 전송하고(=producer ), 메시지를 수신하는(=consumer)를 python으로 작성해보겠습니다. producer 코드는 아래와 같습니다. from kafka import KafkaProducer producer = KafkaProducer( bootstrap_servers='b-1.demo-cluster-1.09mf2p.c4.kafka.ap-northeast-2.amazonaws.com:9092,b-2.demo-cluster-1.09mf2p.c4.kafka.ap-northeast-2.amazonaws.com:9092') for i in range(1,11): msg = '{}-msg'.format(i) producer.send('example_topic', str.encode(msg)) consumer 코드는 아래와 같습니다. from kafka import KafkaConsumer c...
#
consumer
#
producer
#
카프카
#
kafka
#
partition
#
python
#
보장
#
순서
