kafka sink connect

마이크로 서비스 유저 서비스처럼 config에서 설정파일 받게 수정 1. Orders 서비스와 Catalogs 서비스에 Kafka Topic를 적용- Orders 서비스에 요청된 주문의 수량 정보를 Catalogs 서비스에 반영- Orders 서비스에서 Kafka Topic로 메시지 전송 -> Producer- Catalogs 서비스에서 Kafka Topic에 전송된 메시지 취득 -> Consumer 2. 동기화 코드 [1]order-service -> KafkaProducerConfig.java// 카프카 활성화@EnableKafka// 이 클래스를 설정 파일로 사용, bean을 관리@Configurationpublic class KafkaProducerConfig { @Bean // kaf..

1. Kafka1). Kafka란?실시간 데이터 피드를 관리하기 위해 통일된 높은 처리량, 낮은 지연 시간을 지닌 플랫폼 제공- 모든 시스템으로 데이터를 실시간으로 전송하어 처할 수 있는 시스템- 데이터가 많아지더라도 확장이 용이한 시스템- Producer/Consumer 분리- 메시지를 여러 Consumer에게 허용- 높은 처리량을 위한 메시지 최적화 2).  Kafka Broker- 실행된 Kafka 애플리케이션 서버- 3대 이상의 Broker Cluster 구성- Zookeeper 연동 - 역할 : 메타데이터(Broker ID, Controller ID 등) 저장 - Controller 정보 저장- n개 Broker 중 1대는 Controller 기능 수행 - Controller 역할  - 각 Br..