IT 지식 저장소

#개요 이제 고도화 작업은 거의 끝나 갑니다. 이번 시간에는 Order를 위한 Sink Connection을 만들고, 주문 입력 시 Topic에 해당 정보를 전달하고, 다시 해당 정보를 DB에 저장하는 과정을 구현하려합니다. 예전에 언급 드린적있듯이, Kafka를 통해서 어느 포트에서 오든 메시지를 저장하고 하나의 단일 DB에 저장하기 위한 과정을 구현하려 하는 거죠! + 이번 포스팅은 많이 길어질 것 같습니다. 아무래도 마무리 단계이기도 하고 중요한 부분도 있어서 많은 부분을 적어야 할 것 같네요. 지루하시다면 마지막에 최종코드를 첨부할테니 확인해주세요! #OrderController.java(Order-Service) #완성 코드 package com.example.orderservice.contro..

오늘은 정말 삽질을 많이했다. Kafka Connect를 설치하기 위해서는 confluent 라는 어플리케이션을 받아야합니다. 정석적인 방식은 다음과 같습니다. 저는 이렇게 실행했을때 오류가 발생해 정말 오랜시간 동안 삽질을 했습니다. 그래도 제가 아닌 여러분들은 성공할 수 도 있으니 정석적인 루트를 알려드리겠습니다. #cmd 환경에서의 설치 (Windows) #Confluent 패키지 설치 curl -O http://packages.confluent.io/archive/6.1/confluent-community-6.1.0.tar.gz #패키지 압축 해제 tar xvf confluent-community-6.1.0.tar.gz #해당 폴더로 이동 cd confluent-community-6.1.0 #실행..

개요 이번 시간에는 아래와 같은 내용을 배우려 합니다. Kafka Connect의 개념 연동을 위한 MariaDB 설치 #Kafka Connect 란? Kafka Connect는 쉽게 말하면 자유롭게 Data를 Import/Export 해주는 기능입니다. 그리고 해당 기능을 이용하는데는 별도의 코딩이 필요 없습니다. Configuration 설정을 통해서 데이터 이동을 도와줍니다. Standalone mode, Distribution mode를 지원하며, 가장 중요한 것은 RESTful API 통해 지원 하기에 POST-MAN으로 테스트가 용이 합니다. 나머지 내용은 실습을 진행하면서 조금 더 알아보려 합니다. #MariaDB Kafka Connect를 사용하기에 앞서 MariaDB를 설치해야 합니다. ..