pyspark - kafka structured streaming Kafka broker에 저장된 토픽을 streaming을 통해 PySpark를 이용하여 실시간 스트리밍
본 글은 최원영 저 "아파치 카프카 애플리케이션 프로그래밍 with 자바"를 기반으로 작성되었습니다. 저자 github 주소 https://github.com/bjpublic/apache-kafka-with-java
토픽 생성, 프로듀서 레코드 전송, 컨슈터 레코드 출력, 레코드 삭제