kafka-programming

kafka, zookeep 설치 및 실행. 로컬 컴퓨터와 통신해보기.

토픽 생성, 프로듀서 레코드 전송, 컨슈터 레코드 출력, 레코드 삭제

본 글은 최원영 저 "아파치 카프카 애플리케이션 프로그래밍 with 자바"를 기반으로 작성되었습니다. 저자 github 주소 https://github.com/bjpublic/apache-kafka-with-java

pyspark - kafka structured streaming Kafka broker에 저장된 토픽을 streaming을 통해 PySpark를 이용하여 실시간 스트리밍

저번에 작성했던 Producer API에 이어 이번에는 파티션으로부터 메세지를 받는 Consumer API를 작성해보려고 한다.

스트리밍 시도 2편