목록Kafka (2)

김태오

Strimzi를 사용하여 Kafka, Debezium을 쿠버네티스에 띄우기

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

우선 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 2023. 11. 27. 05:04
이전 Prev 1 Next 다음