커스텀 소스 커넥터에서 Thread.sleep (1000) 은 왜 하는거에요?
149
4 asked
섹션 10. 커스텀 소스 커넥터 22:49 보고있는데요.
poll 함수의 상단에 Thread.sleep(1000) 을 하고있는데 왜 1초의 딜레이를 주는지 궁금합니다.
Answer 2
0
안녕하세요. 해당 소스코드에서 Thread.sleep(1000)은 단순히 running 환경 동작 확인을 위한 코드입니다. 로직상 없어도 되는 부분이니 참고부탁드립니다.
0
안녕하세요, 인프런 AI 인턴입니다.
시원한물냉님, 커스텀 소스 커넥터에서 Thread.sleep(1000)을 사용하는 이유에 대해 질문하셨네요.
Thread.sleep(1000) 사용 이유:
부하 경감: 소스 커넥터의
poll메서드는 지속적으로 데이터를 가져오는 역할을 합니다. 만약 너무 자주 호출되면 시스템에 부하를 줄 수 있습니다. 따라서 주기적으로 데이터를 가져오도록Thread.sleep(1000)을 사용하여 약간의 딜레이를 줌으로써 시스템 자원 사용을 최적화합니다.데이터 처리 효율성: 스레드를 잠시 중단함으로써 새 데이터를 가져오는 빈도를 조절할 수 있습니다. 현실적인 시나리오에서는 종종 데이터가 수집원(source)에서 빠르게 변경되지 않는 경우가 많기 때문에, 딜레이를 통해 필요한 경우에만 데이터를 가져오는 것도 가능합니다.
아래의 링크에서 관련해 더 많은 정보를 확인하실 수 있습니다:
- 커스텀 소스 커넥터의 기본 개념들
저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.
consume 이후 lag가 줄어들지 않음
0
71
2
안녕하세요. 강의의 카프카 버전과 현재 시점의 카프카의 차이점 문의 드립니다.
0
102
2
멱등성 프로듀서 retries 관련 질문입니다.
0
95
2
채팅 서비스 개발 시 주의점이 있을까요?
0
95
2
충분히 큰 파티션 생성시 궁금증이 존재합니다.
0
83
2
KTable 키가 없는 레코드 처리
0
70
2
컨슈머 테스트 코드 작성
0
92
2
리밸런스 onPartitionRevoked이 필요한 상황
0
72
2
카프카 클러스터에서 감당 가능한 파티션(레플리카) 수 문의
0
117
2
reset offset 질문
0
73
2
KStreamJoinKTable 실행시 오류
0
74
2
auto.commit.interval.ms 옵션 관련 질문 드립니다.
0
138
2
파티션, 컨슈머 그룹, 컨슈머 관련 질문
0
116
1
java, kotlin
0
126
2
shutdownThread 에 대한 문의 입니다.
0
151
2
zookeeper실행시 오류가 발생합니다.
0
265
2
처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요
0
178
3
파티션 개수와 컨슈머 개수의 처리량 관련 질문
0
162
2
동영상 및 이미지 처리 관련 문의 드립니다.
0
221
2
주키퍼 없이 사용 문의 드립니다.
0
297
1
kafka 를 띄우니 오류가 발생하고 종료합니다.
0
278
3
zookeeper 실행시 오류 .. 무엇을 해야 할까요?
0
217
2
파티션 추가로 해결할 수 있지만 늘어난 파티션은 줄일 수 없지 않나요?
0
192
2
카프카 2.8.2 버전과 많이 차이가 있을까요??.
0
161
2