728x90 전체 글379 OpenSearch 설치 OpenSearch회사에서 오픈서치를 적용하게되어 공부겸 높은 이해도를 높이기 위해 글을 작성해 봅니다. 오픈 서치는 검색엔진 입니다.먼저 설치 방법과 접속을 해보고 OpenSearch, ElasticSearch 에 대해서 알아보겠습니다. OpenSearch 설치opensearch.yaml 작성도커로 실행하기 위해서 yaml 파일을 작성해 줍니다.연습 용이기 때문에 node 는 하나만 지정해 줍니다.opensearch-node1: 노드1 서버를 설치하기 위한 설정opensearch-dashboards: GUI 를 위한 대시 보드OPENSEARCH_INITIAL_ADMIN_PASSWORD=Root123#@! : 어드민 password 지정services: opensearch-node1: # This is.. 2025. 6. 15. [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. 이전 1 2 3 4 ··· 95 다음 728x90 반응형
