Kafka Custom Partitioner 구현하기
Kafka 정리 내용을 보신 후 실습해 보시기 바랍니다. Custom Partitioner란? 기본적으로 Producer는 RoundRobin 방식으로 파티션에 메세지를 분배하는데 이 방식을 Customizing 하여 특정 Partition에 특정 데이터를 넣어주는 것 예제 코드 작성 Producer는 사용자 정보를 불러와서 UserMessage라는 Topic을 Publish하고 Consumer는 UserMessage Topic을 Subscribe 한다. maven 프로젝트 생성 후 pom.xml 파일 아래와 같이 작성 4.0.0 com.wooyoung kafka-demo 0.0.1-SNAPSHOT jar kafka-demo http://maven.apache.org UTF-8 1.8 1.8 org.ap..
Kafka
2019. 1. 22.
공지사항
최근에 올라온 글
최근에 달린 댓글