본문 바로가기

kafka4

Kafka 로그 모니터링 및 Manager(CMAK) 활용한 클러스터 관리 Kafka 등록 정보 확인 및 로그 모니터링을 웹 기반으로 수행하는 방법에는 여러 가지 도구와 접근 방법이 있습니다. 이를 위해 아래에서 몇 가지 일반적인 접근 방법을 설명하겠습니다. Kafka 기본 명령어 및 등록 정보 확인 Kafka 명령어를 사용하여 클러스터 및 토픽에 대한 기본 정보를 확인할 수 있습니다. # Kafka 클러스터 목록 확인 kafka-topics.sh --zookeeper --list # 특정 토픽에 대한 정보 확인 kafka-topics.sh --zookeeper --describe --topic Kafka Manager 사용 Kafka Manager는 웹 기반의 Kafka 클러스터 관리 도구입니다. 이를 사용하여 토픽의 상태, 파티션 및 브로커에 대한 정보를 쉽게 확인할 수 있.. 2023. 12. 21.
대량 데이타 실시간 처리 분산 메시징 시스템 Kafka 구조 및 구성 Apache Kafka는 대용량의 데이터를 안정적으로 수집, 저장 및 처리하기 위한 분산 스트리밍 플랫폼입니다. 주로 대규모 데이터의 실시간 스트리밍 및 이벤트 처리에 사용되며, 여러 소비자에게 데이터를 안전하게 전달할 수 있는 메시징 시스템의 역할을 합니다. 주요 특징 분산 아키텍처: Kafka는 여러 브로커로 구성된 분산 아키텍처를 가지며, 데이터를 여러 노드에 분산하여 안정성과 확장성을 제공합니다. 토픽 기반 메시지 큐: 데이터는 토픽(topic)이라는 카테고리로 구분되며, 생산자(producer)가 메시지를 생성하고, 소비자(consumer)가 해당 토픽에서 메시지를 구독하여 처리합니다. 내결함성: 브로커 중 하나가 실패해도 데이터의 유실 없이 안전하게 처리할 수 있도록 내결함성을 제공합니다. 확.. 2023. 12. 8.
Debezium으로 DB(데이터베이스) 동기화 구축 Debezium은 데이터베이스의 변경 사항을 캡처하고 이를 이벤트 스트림으로 변환하는 오픈 소스 데이터 변경 스트리밍 플랫폼입니다. Debezium을 사용하여 데이터베이스 간 또는 데이터베이스와 다른 애플리케이션 간의 실시간 데이터 동기화를 구축할 수 있습니다. 아래는 Debezium을 사용하여 DB 동기화를 구축하는 과정에 대한 기본적인 정보입니다. Debezium 설치 및 설정: 먼저 Debezium을 설치하고 설정해야 합니다. Debezium은 Kafka Connect 플러그인으로 제공되며, Apache Kafka 클러스터를 사용하여 변경 이벤트를 게시합니다. Kafka와 Kafka Connect를 먼저 설치하고 Debezium 플러그인을 추가해야 합니다. 데이터베이스 연결 구성: Debezium은.. 2023. 11. 11.
Spring Boot, Kafka 및 데이터베이스 서비스 구성 개념 Spring Boot Spring Boot는 스프링 프레임워크를 기반으로 하는 웹 애플리케이션을 빠르게 개발하기 위한 도구입니다. Spring Boot는 자동 구성과 스타터 패키지를 제공하여 프로젝트 설정을 간소화하고 개발 생산성을 향상시킵니다. Spring Boot는 Java 기반의 웹 애플리케이션을 개발하기 위한 프레임워크로, 다음과 같은 주요 개념을 포함합니다. 스프링 부트 스타터 (Spring Boot Starter): 필요한 라이브러리 및 설정을 포함한 스타터 패키지를 제공하여 개발자가 더 쉽게 프로젝트를 설정할 수 있게 해줍니다. 자동 구성 (Auto Configuration): 스프링 부트는 클래스 경로에서 사용 가능한 빈을 자동으로 구성하므로 개발자는 더 이상 복잡한 설정을 작성하지 않아도.. 2023. 10. 12.