Kafka Producer Application

python 파일을 python 이미지 안에 넣어서 이미지를 직접 만들었다.

→ copy 안됨

해결 방법

파일을 직접 copy해서 해결.

pip install kafka를 하게되면 아래와 같은 오류가 생긴다.

따라서 pip install kafka-python으로 해결

간단하게 테스트

from kafka import KafkaProducer
from json import dumps
import time



producer = KafkaProducer(acks=0, compression_type='gzip', bootstrap_servers=['kafka-broker-0.kafka-service.default.svc.cluster.local:9092' ,'kafka-broker-1.kafka-service.default.svc.cluster.local:9092','kafka-broker-2.kafka-service.default.svc.cluster.local:9092'],
                         value_serializer=lambda x: dumps(x).encode('utf-8'))

start = time.time()
for i in range(10000):
    data = {'str' : 'result'+str(i)}
    producer.send('test', value=data)
    producer.flush()
print("elapsed :", time.time() - start)

결과