예외에서 스프링 카프카 중지 컨테이너

Question

자동 커밋을 false로 설정하고 ConcurrentMessageListenerContainer을 사용하여 주제에서 메시지를 소비하고 데이터베이스에 씁니다. 데이터베이스가 다운 된 경우 컨테이너가 설문 조사에서 현재 레코드를 처리하지 못하도록하고 다음에 수행하지 마십시오. poll(). DataSourceHealthIndicator을 구현했으며 데이터베이스 상태를 UP으로 확인한 후 나머지 레코드를 처리하기 위해 컨테이너를 다시 시작하려고합니다.

제안 사항 나머지 레코드 처리를 중단하고 컨테이너를 중지하려면 어떻게해야합니까? consumer.close()을 사용해 보았습니다. 그러나 그것은 프로세스를 멈추지 않고 계속 던지는 소비자는 이미 닫혀 있습니다.

Answer 1

container.stop()으로 전화하십시오. @KafkaListener을 사용하는 경우 리스너 컨테이너 레지스트리에서 stop()으로 전화하면 등록 된 모든 컨테이너가 중지됩니다.