Kafka Streams KStream과 KTable
KStream과 KTable이 같은 토픽을 다르게 해석하는 이유, Stateless/Stateful 연산, KStream-KTable 조인과 Serdes 설정을 코드 중심으로 정리한다.
KStream과 KTable이 같은 토픽을 다르게 해석하는 이유, Stateless/Stateful 연산, KStream-KTable 조인과 Serdes 설정을 코드 중심으로 정리한다.
Consumer/Producer API 직접 조합과 Kafka Streams의 차이를 비교하고, Topology, Task, State Store 등 핵심 아키텍처를 코드로 풀어본다.
__consumer_offsets 토픽의 내부 구조, 자동/수동 커밋 전략 비교, 오프셋 리셋 시나리오와 Consumer Lag 모니터링까지 오프셋 관리 전반을 다룬다.
Spring Kafka의 에러 핸들러 구조와 ErrorHandlingDeserializer, DeadLetterPublishingRecoverer의 내부 동작을 다루고, DLT 토픽 설계와 재처리 전략을 살펴본다.
카프카 스키마 레지스트리가 무엇이고 왜 필요할까? 그리고 사용할 때 체크할 부분들!