김태오

Debezium은 대표적인 CDC(Change Data Capture) 툴이다. CDC를 쓰는 이유로는 데이터베이스의 변화를 빠르게 감지하여 이벤트를 발생시켜 작업을 함에 있다. 도입하게 된 유즈케이스를 간단히 설명하자면, 어플리케이션에서 POST api 인입 -> A 데이터베이스에 정보 저장 -> 외부 api 호출 -> 호출 성공시 B 데이터베이스에 정보 저장 -> 다른 service method들 실행의 과정에서, 외부 api 가 실패하더라도 A 데이터베이스가 업데이트되어 한 트랜잭션에 묶이지 않았기 때문이다. @Transcational 을 걸고 실패시 롤백 핸들링을 하면 되지 않나 싶겠지만, 외부 api 호출을 async로 던지고 있었기에 불가능했다.아무튼 외부 api 호출을 먼저하고, 호출이 성공..

우선 kafka 설치이다. brew install kafka 이후 zkServer start //zooKeeper 시작 kafka-server-start /opt/homebrew/etc/kafka/server.properties //kafka 시작 - brew 로 설치하지 않았다면 /usr/local/~ 에 있음 다음으로 간단하게 topic 을 생성해보자. kafka-topics --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 test 라는 이름의 topic 을 kafka server (localhost:9092) 에 생성한다. replication factor 는 가지고 있을 복사본의..

일단 kafka 설치이다. brew install kafka zookeeper 등 kafka 에 필요한 dependency 들이 모두 설치된다. 우선 pub/sub 이란 무엇인지 알아보자. pub/sub 은 publish/subscribe 의 약자인데, 소프트웨어 아키텍쳐에서 사용하는 메시징 파라다임이다. 메시지란 어떠한 이벤트, 커맨드, 데이터 프로세싱 등에 대해서 publish 하는 쪽에서 subscribe 하는 쪽으로 넘기는 데이터 라 보면 된다. 적절한 비유일지 모르겠지만, ReactJS 에서 사용하는 useEffect 를 예시로 들어보자. function ExampleComponent() { const [count, setCount] = useState(0); // useEffect hook t..