Connect Task 질문

카프카 완벽 가이드 - 커넥트(Connect) 편

작성

151

안녕하세요

우선 좋은 강의 감사드립니다.

다름이 아니라 강의에서 Connect Task 가 thread 로 작동한다고 말씀하신 부분을

한 Worker process 내에서 여러 개의 thread(task) 로 병렬 처리를 할 수 있다 라고 이해했습니다.

그럼 혹시 여러 Task 가 동시에 접근할 수 있는 변수를 선언해서 사용할 수 있을까요?

race_condition 같은 문제를 해결하기 위해 mutex 를 사용할 것 같긴 한데 이러한 구현이 가능한 지 궁금합니다.

감사합니다

답변 1

지식공유자

안녕하십니까,

많은 connector들이 있고, connector별로 특성이 있기 때문에 구현까지는 어떻게 했는지 저도 잘 모르겠습니다.

thread 기반으로 동작은 하지만 동시에 접근할 수 있는 변수를 선언한다든지는 connector 별로 내부 코드를 확인해 봐야 합니다. 하지만 connector의 특성상 충돌을 방지하기 위해서 서로 공유하는 변수들은 없을것 같고, 있어도 최소일 것 같습니다.

감사합니다.

질문자

감사합니다.

별개로 혹시 각각 connector 에서의 log 혹은 stdout 을 볼 수 있는 방법은 connect log 를 방법 밖에 없을까요?

지식공유자

네, connector 로그는 강의에서 처럼 log를 보는 방법외에는 알고 있지 못합니다.

다만 log의 레벨을 조절할 수는 있습니다. 이건 설명이 좀 길어서

참조하시면 중간 쯤에 Change Log Levels 단락이 있는데 여기를 참조해 보시면 좋을 것 같습니다.

감사합니다.

인프런 커뮤니티 질문&답변