728x90 Message Queue/Kafka7 [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. [kafka] EC2 에 kafka 설치 시작하기전 시작 하기전 AWS 에 인스턴스를 생성했다고 가정 하겠습니다. EC2 인바운드 규칙 설정 Host 설정 파일 연뒤 아래와 같이 저장 해당 호스트를 가지고 vi /etc/hosts 127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 ::1 localhost6 localhost6.localdomain6 0.0.0.0 test-broker01 Zookeeper 설치 wget https://downloads.apache.org/zookeeper/zookeeper-3.6.3/apache-zookeeper-3.6.3-bin.tar.gz Zookeeper 환경설정 broker id 생성 vi /var/lib/zookeep.. 2022. 7. 10. 이전 1 2 다음 728x90 반응형
