인프런 커뮤니티 질문&답변

안녕하십니까,

가능합니다.

다만, kafka-console-producer 명령어로는 어려울 것 같고, 직접 Java Client 를 작성하면 됩니다.

섹션 3. Java 기반 Producer 구현 실습 및 Producer 내부 메커니즘 이해 - 02 에 보시면

커스텀 파티셔너(Custom Partitioner) 구현하기 - 02 강의가 있는데, 여기서 Custom Partitioner를 설정하는 Java Client를 설명 드립니다.

근데 해당 강의에서 Customer Partitioner를 구현하지 마시고, 아래와 같이 partitioner.class를 org.apache.kafka.clients.producer.RoundRobinPartitioner로 설정하면 producer에서 Round robin 방식으로 메시지를 보낼 수 있습니다.

props.setProperty(ProducerConfig.PARTITIONER_CLASS_CONFIG, "org.apache.kafka.clients.producer.RoundRobinPartitioner");

Sticky 방식은 위 코드를 제거 하시면 기본이 Sticky 입니다.

굳이 위 강의가 아니더라도 섹션 2. Java 기반 Producer 구현 실습 및 Producer 내부 메커니즘 이해 - 01에서 Java Client 구현 코드 강의를 들으시면 어떻게 구현해야 하는지 아실 수 있을 겁니다.

감사합니다.