IT LAB

[Spring for Apache Kafka] Exactly Once Semantics

1. Exactly Once Semantics읽기 → 처리 → 쓰기 과정이 정확히 한 번만 실행되는 것을 보장 2. 처리 흐름컨슈머KafkaAwareTransactionManager를 리스너 컨테이너에 설정하면, 리스너 호출 전에 트랜잭션을 시작합니다.리스너 내부에서 수행하는 KafkaTemplate 작업들은 트랜잭션에 참여합니다.리스너가 정상적으로 처리하면,producer.sendOffsetsToTransaction()를 호출해서 컨슈머 오프셋을 트랜잭션에 포함시킵니다.이후 트랜잭션을 커밋합니다.리스너에서 예외가 발생하면,트랜잭션을 롤백하고,컨슈머는 오프셋을 다시 설정해서, 실패한 레코드를 다음 poll() 때 다시 읽어 재처리합니다 3. 셋팅spring: kafka: producer: ..

[실전 카프카 개발부터 운영까지] 6. 컨슈머의 내부 동작 원리와 구현

1. 컨슈머 오프셋 관리오프셋컨슈머가 읽은 메시지 위치를 나타내는 번호 __consumer_offest 토픽컨슈머 그룹별로 오프셋을 저장하는 내부 토픽파티션 수와 리플리케이션 팩터 조정 가능offsets.topic.num.partitionsoffsets.topic.replication.factor 기본 동작컨슈머지정된 토픽의 메시지를 읽음오프셋 정보를 __consumer_offest에 기록컨슈머 그룹컨슈머들의 오프셋 추적장애 시, 지정된 오프셋을 통해 복구 가능 2. 그룹 코디네이터그룹 코디네이터컨슈머 그룹의 구성 관리와 오프셋 저장, 리밸런싱 관리를 담당하는 브로커컨슈머 그룹이 브로커에 최초 연결 시, 해당 브로커가 자동으로 그룹 코디네이터로 지정됨구분설명트래킹그룹 멤버와 구독한 토픽의 파티션을 지속적..