<div id="readability-page-1" class="page"><div>
 
 <div id="SE-b857596b-de32-4a42-b5e0-9310eaf20066">
 ​이전 포스팅에서 message 처리가 실패하면 retry (10회) 하는 동안 같은 파티션의 다음 message 들의 처리가 blocking 된다고 설명했다. 그리고, retry 가 모두 실패하면 자동으로 DLT (Dead Letter Topic) 으로 메시지가 들어간다고 설명했는데 이건 잘못된 설명이었던것 같다.​
 </div> 
 <div id="SE-f738edc8-1a6f-4ee6-9e9b-46db14411fc3">
 Spring Kafka 에서는 @RetryableTopic 이라는 어노테이션을 통해 retry 와 관련된 설정을 세밀하게 조정할수 있는데, 이 설정을 해주지 않으면 메시지 처리 실패시 기본적으로 retry 를 시도하긴 하지만 retry 까지 실패하는 경우 dlt 로 메시지가 이동되지는 않는다.​그리고, @RetryableTopic 설정을 했을때는 메시지 처리가 실패하면 retry 하기 전에 retry topic 으로 이동후 별도의 스레드 (컨슈머 스레드를 blocking 하지 않고) 에서 retry 를 시도하는반면, @RetryableTopic 설정이 없는 경우에는 컨슈머 스레드를 blocking 한 상태로 retry 를 실행하기 한다.​이게 단순히 "블로킹 / 논블로킹으로 처리된다" 가 중요한게 아니라, 논블로킹으로 처리되면 "순서보장이 안된다" 는 문제가 발생하는게 중요한것 같다.
 </div> <div id="SE-5e0df6eb-45bc-46b9-bbb3-a56e9e23cdf0">
 <a href="#" onclick="return false;" data-linktype="img" data-linkdata="{&quot;id&quot; : &quot;SE-5e0df6eb-45bc-46b9-bbb3-a56e9e23cdf0&quot;, &quot;src&quot; : &quot;https://mblogthumb-phinf.pstatic.net/MjAyNTEwMjBfMjc4/MDAxNzYwOTI1NjczNzEx.ep7DzgpJY2aBXid2ZwtZiFRmQT-lVjrmnoWDzgDv1P0g._0mx0rH9LF9BFvqP_JusjcyVB_TL9jC3OK5zjZ5TkL0g.PNG/%EC%8A%A4%ED%81%AC%EB%A6%B0%EC%83%B7_2025-10-20_%EC%98%A4%EC%A0%84_11.01.11.png&quot;, &quot;originalWidth&quot; : &quot;688&quot;, &quot;originalHeight&quot; : &quot;589&quot;, &quot;linkUse&quot; : &quot;false&quot;, &quot;link&quot; : &quot;&quot; }">
 <img src="https://mblogthumb-phinf.pstatic.net/MjAyNTEwMjBfMjc4/MDAxNzYwOTI1NjczNzEx.ep7DzgpJY2aBXid2ZwtZiFRmQT-lVjrmnoWDzgDv1P0g._0mx0rH9LF9BFvqP_JusjcyVB_TL9jC3OK5zjZ5TkL0g.PNG/%EC%8A%A4%ED%81%AC%EB%A6%B0%EC%83%B7_2025-10-20_%EC%98%A4%EC%A0%84_11.01.11.png?type=w800" data-width="688" data-height="589" alt="">
 </a>
 
 </div>
 <div id="SE-b612a8dd-2727-4cb9-89e1-545dfb574a2d">
 ​​아래는 예제 코드다. 코드에 @RetryableTopic 을 보면 여러 설정이 있는데 각각에 대한 설명을 하자면,<ul><li>attempts : 시도할 횟수 (= 최초 요청을 포함한 횟수 = 최초 요청 + 재시도 2번)</li><li>backoff : <ul><li>delay : retry 사이에 대기할 delay 시간</li><li>multiplier : delay 가 multiplier 만큼 증가 =&gt; 처음에는 1초, 그 다음에는 2초, 그 다음에는 4초, 그다음에는 8초..</li></ul></li><li>dltTopicSuffix : 기본적으로는 `-dlt` 가 suffix 로 붙는다. 따라서, naming rule 에 따라 '.dlt' 를 명시적으로 써줬다.</li><li>retryTopicSuffix : 마찬가지로 '-retry' 대신 '.retry' 를 사용하도록 명시</li></ul>
 </div> <div id="SE-a8b52d75-58d7-4102-80ea-b2d8929878e7">
 @KafkaListener(
 topics = ["order.create"],
 groupId = "myGroup",
)
@RetryableTopic(
 attempts = "3",
 backoff = Backoff(delay = 1000, multiplier = 2.0),
 dltTopicSuffix = ".dlt",
 retryTopicSuffix = ".retry",
)
fun receiveMessage(order: String) {
 log.info { "Received message $order" }

 val orderDto = objectMapper.readValue(order, OrderDto::class.java)
 val name = orderDto.name
 if (name == "fail") {
 throw RuntimeException("something is wrong...")
 }
 Thread.sleep(2000L)
 log.info { "Done processing order.." }
}
 </div> <div id="SE-a4d4c174-4ee1-49c5-8112-e634c3fede91">
 ​#kafka #retry #retryableTopic #논블로킹재시도 #kafka재시도
 </div> </div></div>

나만의공간。

KIM JUNGHWAN

이전 포스팅에서 message 처리가 실패하면 retry (10회) 하는 동안 같은 파티션의 다음 message 들의 처리가 blocking 된다고 설명했다. 그리고, retry 가 모두 실패하면 자동으로 DLT (Dead Letter Topic) 으로 메시지가 들어간다고 설명했는데 이건 잘못된 설명이었던것 같다. Spring Kafka 에서는 @RetryableTopic 이라는 어노테이션을 통해 retry 와 관련된 설정을 세밀하게 조정할수 있는데, 이 설정을 해주지 않으면 메시지 처리 실패시 기본적으로 retry 를 시도하긴 하지만 retry 까지 실패하는 경우 dlt 로 메시지가 이동되지는 않는다. 그리고, @RetryableTopic 설정을 했을때는 메시지 처리가 실패하면 retry 하기 전에 retry topic 으.......

[kafka] 논블로킹 재시도 - @RetryableTopic

댓글