bjpublic / apache-kafka-with-java Goto Github PK

마스터에 올려주신 소스코드 가 책 내용 중 예제 코드 kafka-consumer-rebalance-listener (109페이지) 랑 조금 다른거 같은데 올려둔 소스코드로 공부하면 될까요?
저자님 새해복 많이 받으세요. 🙇🏻‍♂️

intelliJ 에서 simple-kafka-producer 파일을 만들고 내용을 넣은 후, 로컬에서 토픽을 생성하였는데 'Broker may not be available.' 에러가 나서

1. 인스턴스에서 jps -m 를 실행해보니 Kafka config/server.properties 가 실행이 끊겨있었습니다.
2. 다시 실행시키고 jps 로 확인해봐도 잠시 떠있을 뿐 다시 연결이 끊깁니다.
3. log를 확인해보니 18000ms 세션이 만료되었다고 떴습니다.

• rm -rf /tmp/kafka-logs 를 써 해결이 되었습니다.!! 하지만 원인은 알 수 가 없네요 ㅠ ㅎㅎ 혹시 이런 상황의 원인을 알고 계실까요..? 다음 카프카 실행 시 또 이런 에러가 날까봐 두렵네요 ㅎㅎ

swap 메모리 부족이 원인인지 , 다른 메모리 부족이 원인인지 잘 모르겠습니다.
혹시 swap 메모리 부족이 원인이라면,
swap 폴더를 따로 만들어 swap 메모리를 2G 정도 설정해주면 자동으로 설정이 되는지도 궁금합니다..

bash command 를 찾지 못하는데 해결 방법이 있나요 ??..

실행이 안됩니다... 이 오류 아시면 도와주세요 ㅠㅠ 너무 힘드네요...

책 내 bulid.gradle 은 다음과 같습니다.

jar {
    from {
        configurations.compile.collect { it.isDirectory() ? it : zipTree(it) }
    }
}

그런데 jar 명령이 안되더라고요. 아마 deprecated인듯...?

반면, 다음과 같이 했더니 됩니다.

jar {
    duplicatesStrategy(DuplicatesStrategy.EXCLUDE)
    from {
        configurations.compileClasspath.collect { it.isDirectory() ? it : zipTree(it) }
    }
}

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

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

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