[Kafka] 웹 브라우저 동작 시 Consumer 에 토픽 메세지 전송

● 참고

2023.03.20 - [분류 전체보기] - [Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송

[Kafka] Broker 서버를 이용한 Producer&Consumer 메세지 전송

 

 

> django 프로젝트 코드 수정

● 게시글 저장 부분에 코드 추가

#게시글 db 저장과 동시에 메세지 발행
    producer = KafkaProducer(
        acks=0,
        compression_type='gzip',
        bootstrap_servers=['200.200.200.152:9092'],
        value_serializer=lambda x: dumps(x).encode('utf-8')
    )
    data = {'message': 'posting'}
    producer.send('test', value=data)		# consumer 랑 맞춰줘야 하는 topic 부분
    producer.flush()

 

● 게시글 작성 시 Consumer

consumer terminal