본문 바로가기

스프링 카프카

(2)
스프링 카프카 with Template Source Code 1. 스프링 카프카 카프카 클라이언트에서 사용하는 여러 가지 패턴을 미리 제공한다. 컨슈머를 멀티 스레드로 운영하기 위한 스레드 풀 로직은 스프링 카프카를 사용하면 concurrency 옵션 하나만 추가하면 어렵지 않게 구현할 수 있다. 스프링 카프카 라이브러리는 어드민, 컨슈머, 프로듀서, 스트림즈 기능을 제공한다. 1.1 스프링 카프카 프로듀서 스프링 카프카 프로듀서는 카프카 템플릿이라고 불리는 클래스를 사용하여 데이터를 전송할 수 있다. 카프카 템플릿은 프로듀서 팩토리(ProducerFactory) 클래스를 통해 생성할 수 있다. 카프카 템플릿을 사용하는 방법 기본 카프카 템플릿 사용 카프카 템플릿을 프로듀서 팩토리로 생성하는 방법 1.1.1 카프카 프로듀서 예제 스프링 카프카에서 프로듀서를 사용할.. 더보기
카프카 기본 개념 정리 이 글은 간단하게 카프카의 기본 개념을 용어위주로 정리한 글입니다. 편하게 읽어주시고 틀린 내용이 있다면 언제든 댓글 부탁드립니다. 1. 카프카 구성 1.1 카프카 브로커, 클러스터, 주키퍼 카프카 브로커는 카프카 클라이언트와 데이터를 주고받기 위해 사용하는 주체이자, 데이터를 분산 저장하여 장애가 발생하더라도 안전하게 사용할 수 있도록 도와주는 애플리케이션이다. 하나의 서버에는 한 개의 카프카 브로커 프로세스가 실행된다. 3대 이상의 브로커 서버를 1개의 클러스터로 묶어서 운영한다. 카프카 클러스터로 묶인 브로커들은 프로듀서가 보낸 데이터를 안전하게 분산 저장하고 복제하는 역할을 수행한다. 주키퍼는 카프카의 메타데이터를 관리하는 데에 사용된다. 1.2 컨트롤러 클러스터의 다수 브로커 중 한 대가 컨트롤.. 더보기