|
|
8ff8584a31
|
refactor: DLTProducerTest에서 불필요한 컨슈머 연결 방지를 위한 컨슈머 Mocking
- Kafka 클러스터 실행 없이 테스트를 진행해도 정상 동작해야 함.
|
2025-06-27 14:38:29 +09:00 |
|
|
|
54328767b9
|
feat: 컨슈머 설정 클래스 구현
- 컨슈머 관련 설정 + 메트릭 측정을 위한 MeterBinder 빈
- KafkaConsumer는 Thread-Safe하지 않기에 빈 등록 X
|
2025-06-27 14:37:05 +09:00 |
|
|
|
c891e26b8a
|
feat: 컨슈머 기능 구현
- 3개의 워커스레드 생성 및 실행
- 스프링의 PreDestroy를 이용한 shutdown 로직 구현
|
2025-06-27 14:36:10 +09:00 |
|
|
|
bad7b5725e
|
feat: 컨슈머 워커 스레드 기능 구현
- 오프셋 비동기 커밋 & 예외 처리 & shutdown 기능 구현
|
2025-06-27 14:35:10 +09:00 |
|
|
|
e4b86e6f21
|
feat: 컨슈머 레코드 처리 기능 구현
- 메트릭 측정(ref: ce20f85c)을 위한 로직
- 레코드 자체를 처리하는 비즈니스 로직은 없음.
|
2025-06-27 14:34:13 +09:00 |
|
|
|
69bd95b981
|
feat: 컨슈머 리밸런스 발생시 처리 기능 구현
- 일단 로깅 및 Manual Commit만 진행
|
2025-06-27 14:32:11 +09:00 |
|
|
|
26f39596f0
|
feat: application.yml의 workerThreads로 지정된 값 만큼의 스레드 풀 및 크기값을 가지는 클래스
- 스레드 풀이 필요한 곳, 단순히 스레드 수가 필요한 곳 모두에서 사용하기 위함.
|
2025-06-27 14:31:19 +09:00 |
|
|
|
ce20f85c04
|
feat: Plaintext와 Ssl에서의 전송 시간 메트릭 측정에 사용되는 ConsumerStats 클래스
|
2025-06-27 14:29:46 +09:00 |
|
|
|
3e9e8ebe2a
|
feat: 로컬에서의 정상 실행을 확인하기 위한 카프카 클러스터 실행용 스크립트
|
2025-06-27 14:27:55 +09:00 |
|
