require('develop')

필자 환경 SpringBoot 3.3.1 Spring Cloud Stream Kafka Binder Situation 2개의 Kafka Listener 가 있는 상황, 각각을 A, B라고 칭하자 A는 변경 감지를 위한 Listener, B는 최신 데이터를 1회 성으로 처리하는 Listener 흔히 말해 A는 CDC(Change Data Capture) 처리용, B는 Migration 처리용이라고 볼 수 있다. Migration 데이터를 다 처리한 뒤에, CDC Data를 처리하고 싶은 상황이다. Migration Data는 처리하려는 시점에서 최신 데이터를 사용할 것이다. Migration Data를 Query 했을 때 당시는 최신 데이터지만, 이를 처리하는 동안(Database에 저장한다던가, 외부 API로 처리한다던가 등)에 데이터의 변경이 언제든지 일어날 수 있다. Mi.......

[Spring Kafka] 원하는 타이밍부터 lag을 쌓아두고 싶을 때

댓글