
카프카 컨슈머 graceful shutdown 구현 방식 비교 (spring, reactor)

·
카테고리 없음
카프카 컨슈머 구현 시에 graceful shutdown 의 구현 방식을 살펴본다. 1. kafka-clients카프카 Java Client 를 이용한 컨슈머 폴링 시에 shutdown 을 구현한 코드는 다음과 같다.public void run() { try { consumer.subscribe(topics); while (true) { ConsumerRecords records = consumer.poll(Long.MAX_VALUE); records.forEach(record -> process(record)); consumer.commitSync(); } } catch (WakeupException e) { // ignore, we're closi..