inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

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

Wakeup을 이용하여 Consumer를 효과적으로 종료하기

addShutdownHook이 제대로 작동하지 않는것 같습니다

해결된 질문

487

edk2613

작성한 질문수 1

0

IntelliJ에서 ConsumerWakeup파일을 실행하고 종료 시,

logger.info("main program starts to exit by calling wakeup");

이 콘솔에 출력되지 않고 아래와 같은 오류가 출력됩니다.

> Task :consumers:ConsumerWakeup.main() FAILED

2 actionable tasks: 1 executed, 1 up-to-date

FAILURE: Build failed with an exception.

* What went wrong:

Execution failed for task ':consumers:ConsumerWakeup.main()'.

> Build cancelled while executing task ':consumers:ConsumerWakeup.main()'

* Try:

> Run with --stacktrace option to get the stack trace.

> Run with --info or --debug option to get more log output.

> Run with --scan to get full insights.

* Get more help at https://help.gradle.org

BUILD FAILED in 11s

오후 4:02:44: 실행이 완료되었습니다 ':consumers:ConsumerWakeup.main()'.

 

 

만약, 커버리지 모드로 구동을 할 경우 아래와 같이 정상적으로 로그가 출력됩니다.

[Thread-2] INFO com.example.kafka.ConsumerWakeup - main program starts to exit by calling wakeup

[main] ERROR com.example.kafka.ConsumerWakeup - wakeup exception has been called

[main] INFO com.example.kafka.ConsumerWakeup - finally consumer is closing

Class transformation time: 0.1235649s for 1928 classes or 6.408967842323652E-5s per class

 

 

VirtualBox 세팅 문제로 별개의 Bare-Metal 리눅스 서버를 구성하여 사용중입니다.

Java 버전, Gradle버전, implementation환경 등은 강의와 같은 상태인데 혹시 어떤게 문제일까요?

kafka 데이터-엔지니어링

답변 1

0

권 철민

안녕하십니까,

음, VM 문제는 아닌것 같고, IntelliJ Build의 문제인것 같습니다만,

아래 URL과 같이 Gradle을 IntelliJ IDEA 로 변경해 보시겠습니까?

https://spongeb0b.tistory.com/208

감사합니다.

0

edk2613

말씀하진 방법으로 해결하였습니다. 감사합니다!

virtual box 설치 문제

0

62

2

카프카 서버 구축 관련 문의

0

67

2

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

0

70

2

Zookeeper에서 KRaft

0

78

1

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

0

98

2

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

0

72

2

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

0

83

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

158

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

203

2