Free Lines Arrow
본문 바로가기
728x90

분류 전체보기381

[Docker] gradle을 이용한 이미지 생성 및 푸시 gradle 을 이용하여 이미지를 생성하고 푸시한다.  라이브러리 // Docker // https://mvnrepository.com/artifact/com.bmuschko.docker-remote-api/com.bmuschko.docker-remote-api.gradle.plugin implementation 'com.bmuschko.docker-remote-api:com.bmuschko.docker-remote-api.gradle.plugin:9.4.0'// https://mvnrepository.com/artifact/com.bmuschko.docker-java-application/com.bmuschko.docker-java-application.gradle.plugin i.. 2025. 2. 13.
[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.
728x90
반응형