Sticky, RoundRobin 설정
Sticky, RoundRobin 설정을 직접 할 순 없나요? 성능비교를 직접 해보고싶어서요.
- 먼저 유사한 질문이 있었는지 검색해보세요.
- 서로 예의를 지키며 존중하는 문화를 만들어가요.
- 잠깐! 인프런 서비스 운영 관련 문의는 1:1 문의하기를 이용해주세요.
답변 1
0
안녕하십니까,
가능합니다.
다만, 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 구현 코드 강의를 들으시면 어떻게 구현해야 하는지 아실 수 있을 겁니다.
감사합니다.
강의가 부족한 것이 아니라, 누구나 쉽게 이해할 수 있도록 매우 단순하게 설계된 것입니다.
0
22
0
소스 코드 자료를 다운을 받았는데 압축 파일에 문제가 생긴 것 같습니다.
0
674
1
application.yml args에러발생이유
3
713
1
mac os ) zip 파일 dataframe 오류
0
666
1
카프카 ISR 개념 부분 질문
0
484
1
스프링 시큐리티 문의 (webSecurityConfigurerAdapter 취소선)
0
1845
1
catalog 테이블 자동 create-drop 가 안됩니다.
0
1028
2
카프카 커넥터를 두가지 사용하는 이유
0
903
1
H2 최신 버전 사용 시 server mode 사용에 따른 application.yml 파일 설정(테이블은 생성됐는데 data.sql INSERT 안될 시 참고)
13
1275
2
멀티브로커에서 consumer 사용하기
0
634
1
멀티 브로커에서 브로커 중지되는 문제
0
507
1
클러스터 환경구성시 replication factor 1일때 메시지전송 관련 질문
0
446
1
테스트 환경 관련 질문입니다.
1
543
1
카프카 서버기동에서 질문있습니다.
0
316
1
안녕하세요, at Least once 관련 질문이 있습니다!
0
270
1
Consumer group 이 지정된 consumer의 auto.offset.reset
1
766
1
다음 강의 오픈 일정이 궁금합니다!
0
344
1
카프카와 주키퍼랑 통신할때는 브로커 서버의 어느 컴포넌트를 사용해 통신하나요?
0
351
1
만약에 동시에 브로커 서버가 주키퍼한테 리더를 요청하면 누가 리더가 되나요?
0
496
1
동기 Commit과 ConsumerNetworkClient의 Poll() 관련 질문드립니다!
0
347
1
하나의 컨슈머가 서로 다른 토픽을 subscribe하면
0
634
2
NameServer를 찾을 수가 없다고 합니다!
0
275
1
NoCommit의 경우 Offset을 어떻게 알고 요청을 하게 될까요?
0
508
1
virtual box 네트워크 설정 영상이 없어요.
0
279
1