inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

카프카 완벽 가이드 - 코어편

Consumer 파티션 할당 전략 실습 - Cooperative Sticky 방식 할당 실습

CooperativesStickyAssignor 파티션 할당 전략 에러

해결된 질문

766

의탕

작성한 질문수 2

0

안녕하세요 강사님 좋은 강의 감사합니다.

 

파티션 할당 전략 중 CooperativesStickyAssignor 전략 실습중에 에러가 발생하였습니다

 

에러 내용은 두번째 컨슈머를 기동하면서 첫번째 컨슈머 콘솔에서

"Request joining group due to: group is already rebalancing" 라는 에러가 발생하면서 리밸런싱이 완료되지 않아 어느 컨슈머에도 파티션이 할당되지 않는 문제가 발생합니다.

 

해당 에러는  타임아웃이 나기전까지 반복해서 발생하며 이후에는 두 컨슈머 모두 종료됩니다

 

 

해결방법좀 부탁드립니다ㅠ.ㅠ

kafka 데이터-엔지니어링

답변 1

1

권 철민

안녕하십니까,

먼저 오류 메시지를 보면 group is already rebalacing 이 나오는데, 일단 kafka를 재기동하시고 다시한번 수행을 부탁드립니다. 그래도 오류 메시지가 나오면,

  1. cooperative sticky가 kafka version 3.2에서 제대로 동작이 안될 수가 있습니다. 현재 강의 실습 카프카 버전은 kafka 3.1 입니다. 혹시 kafka 3.2이상에서 실습을 하고 계시는지 확인 부탁드립니다. 아마 cooperative sticky 오류의 많은 부분은 kafka 3.2이상에서 문제인걸로 보입니다.

     

  2. kafka 3.1인데도 계속 오류가 발생하면 일단 kafka를 재기동하시고, application은 수행하지 않은 상태에서 kafka-consumer-groups --bootstrap-server localhost:9092 --list 를 해서 현재 떠 있는 consumer group 이 있는지 확인 및 여기에 글 업데이트 부탁드립니다.

감사합니다.

0

의탕

감사합니다 강사님

3.1 버전으로 변경하니 정상적으로 동작됩니다!

빠른 답변 감사드려요~

virtual box 설치 문제

0

62

2

카프카 서버 구축 관련 문의

0

67

2

카프카 토픽 Key 타입 변경에 관한 질문

0

70

2

Zookeeper에서 KRaft

0

78

1

카프카 학습과 관련하여 질문 드립니다

0

97

2

파티션 증가시 비용 증가 고려

0

71

2

Kafka 초기 Partition 개수 설정 관련 질문

0

82

2

VM 과 도커의 차이

0

139

2

vm 어댑터설정 문의

0

78

2

Cooperative Sticky Rebalancing 질문

0

58

2

consumer 설정 질문

0

68

2

consumer.poll 질문입니다.

1

69

2

mainThread.join() 관련 질문

0

57

2

문의

0

153

2

멀티 브로커 설정 중 포트 충돌 발생

0

120

2

Consumer Group 강의 Lag 질문있습니다!

0

107

2

강의 설명 및 코드 정리

0

174

2

실습 코드는 어디서 받나요.. 아무리 찾아도 엄네요..

0

151

1

java.nio.BufferUnderflowException 에러 발생합니다..

0

157

3

KafkaTimeoutError:

0

157

2

acks 1 이면 비동기가 아니지 않나요?!

0

185

2

Producer의 메시지 비동기화 전송 구현 강좌 내용 중 질문

0

109

2

자문자답: 데이터 누락된다고 하시는 분 참고하세요.

0

216

2

자문자답: kafka Error connecting to node utuntu-20.myguest.virtualbox.org:9092

0

201

2