109-110 페이지, 챕터 3, 3.4.2 컨슈머 API, "리밸런스 리스너를 가진 컨슈머", 예제 코드 | kafka-consumer-rebalance-listener 에 대한 질문입니다.
4번 태그가 달린 코드 부분, consumer.commitSync(currentOffsets), 이 어떻게 실행 가능한가요?
consumer를 RebalanceListener에서 참조 할 수 없는데요.
110 페이지 4번 설명을 보면 꼭 있어야 할 거 같아서요.
#5 에서도 비슷한 맥락에 질문한 것 같지만, 단순히 자바 클래스로 추출한 것 외에 이슈가 있는거 같네요.