Kafka 생산자 및 소비자 오류 복구 메커니즘
생산자 측면 재시도 구현
메시지 전송 실패 시 복구를 위해 생산자 구성에서 재시도 매개변수를 설정합니다. 비동기 전송과 콜백 핸들러를 활용하며, 멱등성 보장이 필수적입니다.
재전송 설정 예시
Properties config = new Properties();
config.setProperty("bootstrap.servers", "kafka-server:9092");
config.setProperty("key.serializer", StringSerializer.class. ...
7월 6일 18:49에 게시됨