pricelees/understanding-kafka-consumer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[#9] poll 작업이 완료되었다고 판단하는 기준 수정 #10

Merged
pricelees merged 2 commits from refactor/#9 into main 2025-06-27 07:13:25 +00:00
Conversation 0 Commits 2 Files Changed 3 +101 -2
pricelees commented 2025-06-27 07:13:18 +00:00
Owner
Copy Link

📝 관련 이슈 및 PR

PR과 관련된 이슈 번호

✨ 작업 내용

RecordProcessor에서 비어있지 않은 레코드를 받은 경우 emptyPollCount 값을 0으로 초기화하도록 수정하여 5회 연속으로 비어있는 레코드를 받는 경우에만 poll 작업이 종료되었다고 판단.

🧪 테스트

  1. 5회 연속으로 빈 레코드를 받는 경우에 ConsumerStats에 해당 소요시간이 기록되는지 확인
  2. 5회이긴 하나 연속이 아닌경우 기록되지 않음을 확인.
  3. 테스트의 용이성을 위해 ConsumerStats에 package-private getter 추가

📚 참고 자료 및 기타

<!-- 제목 양식 --> <!-- [이슈번호] 작업 요약 (예시: [#10] Gitea 템플릿 생성) --> ## 📝 관련 이슈 및 PR **PR과 관련된 이슈 번호** - #9 ## ✨ 작업 내용 <!-- 어떤 작업을 했는지 알려주세요! --> RecordProcessor에서 비어있지 않은 레코드를 받은 경우 emptyPollCount 값을 0으로 초기화하도록 수정하여 5회 연속으로 비어있는 레코드를 받는 경우에만 poll 작업이 종료되었다고 판단. ## 🧪 테스트 <!-- 어떤 테스트를 생각했고 진행했는지 알려주세요! --> 1. 5회 연속으로 빈 레코드를 받는 경우에 ConsumerStats에 해당 소요시간이 기록되는지 확인 2. 5회이긴 하나 연속이 아닌경우 기록되지 않음을 확인. 3. 테스트의 용이성을 위해 ConsumerStats에 package-private getter 추가 ## 📚 참고 자료 및 기타 <!-- 참고한 자료, 또는 논의할 사항이 있다면 알려주세요! -->
pricelees added 2 commits 2025-06-27 07:13:18 +00:00 
- 검증을 위해 ConsumerStats 에서 package-private Getter 추가
pricelees merged commit 6eac52c3b8 into main 2025-06-27 07:13:25 +00:00
pricelees deleted branch refactor/#9 2025-06-27 07:13:25 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
pricelees
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: pricelees/understanding-kafka-consumer#10
No description provided.
Delete Branch "refactor/#9"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?