Skip to content

onPartitionsRevoked 에서 offset commit #7

@flavono123

Description

@flavono123

109-110 페이지, 챕터 3, 3.4.2 컨슈머 API, "리밸런스 리스너를 가진 컨슈머", 예제 코드 | kafka-consumer-rebalance-listener 에 대한 질문입니다.

4번 태그가 달린 코드 부분, consumer.commitSync(currentOffsets), 이 어떻게 실행 가능한가요?
consumerRebalanceListener에서 참조 할 수 없는데요.
110 페이지 4번 설명을 보면 꼭 있어야 할 거 같아서요.

#5 에서도 비슷한 맥락에 질문한 것 같지만, 단순히 자바 클래스로 추출한 것 외에 이슈가 있는거 같네요.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions