kafka recursive

problem 코틀린 - 자바 - 위 에러는 코틀린과 자바 같은 오류인데 카프카 -> 서버 데이터를 받아오려고 하는데 데이터가 맞지 않아 서버 롤백 > 카프카에서 서버로 데이터 삽입 > 서버 롤백 > 데이터 삽입 ... 무한으로 흘러가서 발생하는 오류였다... ListenerConsumer 클래스의 run( ) 메소드를 보면 아래와 같이 while 형태로 구현되어있다. while (isRunning()) { try { pollAndInvoke(); } catch (...) { ... } ... catch(Exception e) { handleConsumerException(e); } } 결국 commit이 되지 않아, 같은 offset에서 계속 재시도하게 됩니다. 이로 인해, spring-kafka는 E..
imSoo
'kafka recursive' 태그의 글 목록