Docker를 사용한 Apache Flink와 Flink Job 올리기(2) - Flink Job Example
사실상 코드는 책에서 제공 해 주는 코드를 실행하기 때문에, 주의 해 주어야 할 것은 Maven 설정을 잘 해주는 것과 Java
Stream tag description
모든 태그 보기사실상 코드는 책에서 제공 해 주는 코드를 실행하기 때문에, 주의 해 주어야 할 것은 Maven 설정을 잘 해주는 것과 Java
Stream Processing with Apache Flink 책을 참고해 Docker로 Flink 환경을 구축합니다.
Python에서 Kinesis Datastream에 연동하여 데이터를 주고/받는 과정을 정리 해 보자
Python을 사용해서 Kafka consumer와 producer를 구현해본다. kafka-python 라이브러리를 활용하여 메시지를 발행하고 구독하는 방법을 알아본다.
Apache Kafka는 실시간으로 기록 스트림을 게시, 구독, 저장 및 처리할 수 있는 분산 데이터 스트리밍 플랫폼이다. Docker를 사용해서 Kafka 환경을 구축하고 기본적인 메시지 송수신을 테스트해본다.
Flink 작업을 위해서 Apache Flink 책인 "Stream Processing with Apache Flink: Fundamentals, Implementation, and Operation of Streaming Applications" 를 참고했으며 예제코드를 다운받아 작성했다.
이번 글의 내용은 Apache Flink 책인 "Stream Processing with Apache Flink: Fundamentals, Implementation, and Operation of Streaming Applications" 를 참고했으며 직접 개발환경을 세팅 해 보고 작성했다.