728x90 분류 전체보기380 [Reactive Programming] Thread and Schedulers Thread and Schedulers리액티브에서 동작하는 쓰레드를 알아보자.병렬처리를 하면서 가장 중요한 개념이자 알아야 되는 사항이라고 생각한다. Mono, Flux 는 스스로 쓰레드를 지정하지 않는다.모노 플럭스는 직접 사용자가 쓰레드를 지정해줘야 해당 쓰레드에서 동작한다.그리고 이전에 사용했던 쓰레드를 그대로 사용한다.아래 코드는 쓰레드를 생성해서 플럭스를 수행해보는 예제다.package com.p8labs.reactive.scheduler_and_threding;import lombok.extern.slf4j.Slf4j;import reactor.core.publisher.Flux;import reactor.core.publisher.Mono;@Slf4jpublic class ThreadEx {.. 2025. 1. 11. [Kafka] 카프카 재처리 With DLQ2 - 코드 카프카 재처리를 위한 에러 핸들러1. CommonErrorHandler- 에러 핸들러를 오버라이드 해서 처리하는 방법2. DefaultErrorHandler- 기본 에러 핸들러에 backoff 를 설정하여 처리하는 방법 차이점CommonErrorHandlerDefaultErrorHandler (CommonErrorHandler 를 인터페이스 사용)Kafka Streams와 Kafka Connect에서의 공통 오류 처리Kafka Connect에서의 기본에러 처리복잡한 오류 처리 로직을 커스터마이즈 가능기본적인 예외 처리 (예: 로그 기록, 재시도 등) 코드 구현- 둘다 CommonErrorHandler 를 인터페이스로 가지고 있기 때문에 OCP 패턴을 만족한다.- 그렇기 때문에 간단하게 @Primary 를.. 2025. 1. 11. [Kafka] 카프카 재처리 With DLQ1 - 기본구성 카프카 재처리 카프카를 사용하여 컨슈머에서 에러 발생하는 경우 재처리 시도를 구현해본다. 재처리 조건TimeOutException DLQ 조건재처리 익셉션이 아닌경우재처리가 3회 초과 되었을경우 플로우 Docker 설정kafka 띄우기docker-compose -f ./docker-kafka.yaml updocker-kafka.yamlversion: '2'services: zookeeper: image: wurstmeister/zookeeper container_name: zookeeper ports: - "2181:2181" kafka: image: wurstmeister/kafka:2.12-2.5.0 container_name: kafka ports.. 2024. 12. 24. [추천] 소크라테스 익스프레스 철학을 입문하기 좋은책이다아이와 같이 여행을 하면서 철하자들에 대해 생각해 보고 배경 지식 까지 재미있게 설명해 준다어려운 이야기도 쉽게 풀어 이해를 돕는다스스로를 돌아 보고 철학자들의 생각과 책의 내용을삶에 적용해 볼 만한 것들이 많다 흠 잡는것을 좋아하는 사람은 어떻게해서 든지 흠을 찾아내고 좋은것을 볼 줄 아는 사람은 쓰레기장에서도 좋은것을 찾아 낸다사건에 대해 바로 반응 하지말고 생각하는 과정을 추가 해라 정말 화가 날 만한 상황인가? 내가 급하게 행동함으로 어떤 결과를 가져 올까? 2024. 11. 27. 이전 1 2 3 4 ··· 95 다음 728x90 반응형
