728x90 Message Queue15 [Kafka] docker 카프카 설치 카프카 도커 설치 먼저 서버 2대로 실습을 해본다. 카프카 서버 주키퍼 서버 docker compose 를 쓰면 되지만 직접 설치해 보고 연동을 해본다. 2개 도커를 docker network 로 연결을 해줘야 통신이된다. Zookeeper 설치 1. 우분투 이미지를 가져온다. docker pull ubuntu 2. zookeeper 설치를 위한 ubuntu 를 띄운다. docker run -it -p 2181:2181 --name zookeeper ubuntu 아래처럼 도커가 띄워진걸 확인한다. 3. zookeeper 도커에 접속 docker attach zookeeper 4. 기본 설정 및 zookeeper 다운로드 apt-get update apt-get install -y wget // wget .. 2023. 8. 18. [Kafka] 카프카 Error Handler 적용 ErrorHandler 카프카 컨슈머에서 에러가 발생했을경우 어떻게 처리를 할까? consumer config 에 error handler를 적용해 주면 된다. ErrorHandler package com.example.demo.handler; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.common.TopicPartition; import org.springframework.contex.. 2022. 12. 23. [Kafka] 카프카 Json 데이터 주고 받기 ProductInfo package com.example.demo.dto; import lombok.AccessLevel; import lombok.Getter; import lombok.NoArgsConstructor; import lombok.ToString; @ToString @NoArgsConstructor(access = AccessLevel.PROTECTED) @Getter public class ProductInfo { private String productName; private Integer price; public ProductInfo(String productName, Integer price) { this.productName = productName; this.price = pr.. 2022. 12. 23. [Kafka] 카프카 String 데이터 주고 받기 카프카를 사용하여 스트링을 주고 받아 보자 yaml spring: kafka: producer: bootstrap-servers: localhost:9092 acks: all listener: ack-mode: MANUAL_IMMEDIATE type: SINGLE consumer: bootstrap-servers: localhost:9092 ProducerConfig package com.example.demo.config; import com.example.demo.dto.MessageTemplate; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.serialization.StringSeria.. 2022. 12. 23. 이전 1 2 3 4 다음 728x90 반응형
