제목 자체가 좀 자극적이다. 한국에 있는 많은 사람들이 외국에서의 생활을 동경한다. 나도 그랬으니까.
오늘은 내가 왜 캐나다로 오게 되었고 어떠한 준비를 하였나 간단하게 공유해볼까 한다.
Trigger
예전부터 해외에서 생활을 싶었는데, 한 마디의 말이 날 움직이게 만들었다. 어느날 장모님께서 "해외에서 한번 살아보는 것이 어때? 아이들에게 좋을 것 같은데?" 그러면서 한때 방송에 나왔던 캐나다 용접공의 다큐멘터리를 알려주셨다. 이 일을 계기로, 한국에서의 나의 목표는 캐나다로 이민을 가는 것이 되었다.
이민을 위한 준비 - 직장
목표가 정해졌을 때쯤 난 제조업에서 Software Engineer를 하고 있었다. 펌웨어 프로그래머로 시작하여 Software Quality Engineer로 전형하면서 Test Automation으로 관심을 가지게 되었다. 이 때쯤 캐나다에서 IT 관련 잡이 많고 IT 관련 직종이라면 이민의 성공률이 높다는 얘기를 들었지만, 캐나다에서 펌웨어 관련된 직업이 많지 않았다. 이때 내가 사회초년생때 전자회사를 택했을까를 후회했다.
그러던 찰나, 이민에 대한 목표를 설정한 시점에서 한 스카우터에게서 Job Description이 오게된다. 캐나다에 지사가 있는 게임회사의 Software Quality Engineer 자리였다. 뭔가 운명같은 느낌을 받으면서 지원을 하게 되었다. 미국계 게임회사였기 때문에 영어가 필요하였는데 그렇게 잘할 필요가 없었고, 마침 IELTS 공부를 하고 있던터라 이 성적으로 어필을 하였고, 취업에 성공하게 된다.
회사를 옮기고, 일을 시작하면서 나 자신의 실력이 많이 부족하다는 것을 많이 느꼈다. Industry를 변경하게 된 것도 있지만 그간 Software 개발을 위한 자기계발이 너무 안되어 있다는 생각이 많이 느꼈다. 그래서 열심히 일했다. 많이 배우려고 했고, 어려운 Role도 맡아서 하고, 개발팀과 친하게 지내면서 많이 배웠다. 그렇게 배우고 실력을 키우다보니 어느덧 4년의 시간이 지났고, 애들이 커가고 있었기 때문에 적응을 위해 결심을 해야 했다.
그래서 회사를 그만두고, 유학 후 이민으로 캐나다로 옮기게 되었다.
이민을 위한 준비 - 영어
결론적으로 지금도 영어를 잘 못한다. 영어는 어렵다. 잘 늘지 않는다.
처음 캐나다 이민을 목표로 하고 가장 먼저 알아본 것이 유학 후 이민이었다. 이 유학 후 이민은 캐나다 컬리지에서 일정기간 학교를 다녀서 졸업을 하면 Post Graduation Work Permit이 나오고 이걸로 취업 후에 영주권을 받고 쭉 지내게되는 코스다. 그리고 학교를 들어가기 위해서는 영어 성적이 필요하다. 각 College마다 기준이 되는 성적이 있고, 그 공인점수가 있어야 바로 입학이 가능하다.
하지만, 영어 점수가 모자를 경우에도 방법은 있다. ELL코스라고 각 학교마다 영어 코스가 있고 내부 영어코스를 이수하면 입학할 수 있는 자격이 부여된다. 이 코스는 시작하는 영어 수준에 따라 기간이 다르다. 결국은 영어 성적이 필요하다.
내가 처음 컬리지를 준비할 때에는 IELTS로 Overall Lv 6가 보통이었는데 이제 Each Lv 6가 요구되는 것 같다. 날이 갈 수록 어려워진다.
2021년 1월 학기를 목표로 준비하다가 코로나로 9월학기로 연기 했었는데 1월학기에는 그냥 입학이 가능했지만 9월학기에 기준이 올라 성적을 추가로 만들어야 했다. 다행이 성적을 만들어서 영어코스 없이 입학이 가능했다.
입학을 위한 영어공부 말고, 일상회화에 대한 공부를 얘기해보자면, 캐나다 이민을 결심하면서 부터 회사에서 지원하는 전화영어를 꾸준히 하려고 했고, 영어 관련 유투브를 많이 보았다. 1만시간의 법칙이라는 것을 약간 믿는 편이라 잘 되지 않더라도 많은 양의 영어를 귀로 들을 려고 했고, 한마디라도 해보려고 했다. 하지만 지금 현시점에서 크게 달라진 것 없다. ㅎㅎ
하지만, 계속 영어를 옆에 두는 것이 중요하다.
현재의 내모습
너무 내용이 길어지면 지루하니 결론부터 얘기하겠다.
현재 나는 유학생 신분으로 밴쿠버의 한 College에서 2학기를 수강중이다.
학교 생활은 생각보다 쉽지 않은데 이것은 나중에 다른 포스트로 공유해볼까한다.
하지만 유학생 신분이 오래갈 것 같진 않다.
1학기 때부터 몇몇 회사들과 면접을 보았은데 한 회사에서 오퍼를 받아서 LMIA를 진행 중에 있고, 5월쯤부터 일할 것 같다.
Kafka 의 설정을 마무리하고 나면 이제 Kafka로 Message를 보낼 수 있게 된다. 이 포스트에서는 Kafka Topic으로 Message를 Publish 하는 예제를 공유하고자 한다.
Kafka에서 메세지를 생산하고 publish 하는 주체를 Producer라고 한다. 나의 Project에서 auth service는 JwtToken을 만들고 이 값을 redis에 저장하고 token을 확인할 때마다 redis에서 값을 가져와서 비교하고자 한다.
Kafka 설정시에 2가지의 시나리오가 있어서 KafkaTemplate과 ReplyingKafkaTemplate을 설정하였다. 이 2가지에 대한 Message Publish를 알아보도록 하자.
KafkaTempate & ReplyingKafkaTemplate
KafkaTemplate 을 이용해서 메세지를 보낼 때 primitive한 type으로 보낼 수 있지만, 각 서비스에서 데이터를 관리하기 위해서는 보통 Obejct로 많이 보내게 된다. 특정 Object 형태로 KafkaTemplate을 설정해서 사용할 수 있지만 메세지의 종류가 많아질 경우 이 설정 또한 방대해져서 관리가 힘들 수도 있다.
그래서 난 범용 Object type을 Json을 Serialilze를 하여 Consumer 측에서 해당 Message로 Object Mapping을 하여 사용할 수 있도록 하였다. 이렇게 할 경우 공용 설정을 통해서 설정 부분의 코드를 줄일 수 있다. 하지만, Cosumer쪽에서 Message에 따라 Casting을 해줘야 하는 불편함은 존재한다. 선택의 문제니 필요에 따라 사용하면 될 것 같다.
예제를 위해서는 몇가지 파일이 필요하다.
1. Topic : 사용하는 Topic 값을 정의
(이 Topic의 경우 사용하는 Producer와 Consumer가 함께 가지고 있어야 하는데 어떻게 하면 잘 관리할 수 있을지 고민중이다. )
public class JwtTokenTopic {
public static final String TOPIC_CREATE_JWT_TOKEN = "topic.create.jwt.token";
public static final String TOPIC_REQUEST_JWT_TOKEN = "topic.request.jwt.token";
public static final String TOPIC_REPLY_JWT_TOKEN = "topic.reply.jwt.token";
}
2. Message Object : 메세지로 사용되는 Object들이다, Publish에 사용되는 2가지 간단한 메세지와 응답으로 받는 값을 Mapping 해줄 Object를 정의한다.
@Getter
@Setter
@Accessors(chain = true)
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Schema(description = "JwtToken Cache Creation Message")
public static class CreateMessage {
@Schema(example = "1L")
private Long accountId;
@Schema(example = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.....")
private String jwtToken;
@Schema(example = "10L")
private Long expiration = -1L;
public static CreateMessage from(Account account, Date expireDate) {
Long expiration = -1L;
if (expireDate != null) {
expiration = DateTimeUtils.getSecondsBetweenDates(new Date(), expireDate);
}
return new CreateMessage()
.setAccountId(account.getId())
.setJwtToken(account.getJwtToken())
.setExpiration(expiration);
}
}
@Getter
@Setter
@Accessors(chain = true)
@AllArgsConstructor
@NoArgsConstructor
@ToString
@Schema(description = "JwtToken Cache Request Message")
public static class RequestMessage {
@Schema(example = "1L")
private Long accountId;
}
@Getter
@Setter
@Accessors(chain = true)
@AllArgsConstructor
@NoArgsConstructor
@ToString
@JsonInclude(NON_NULL)
@Schema(description = "JwtToken Cache Info")
public static class JwtTokenInfo {
@Schema(example = "ff6681f0-50f8-4110-bf96-ef6cec45780e")
private String id;
@Schema(example = "1L")
private Long accountId;
@Schema(example = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.....")
private String jwtToken;
@Schema(example = "2021-01-01T00:00:00")
@JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss")
private LocalDateTime updatedAt;
}
3. Callback 함수 파일 : 이 파일은 Service layer에서 Message을 보내고 난 후 ack를 확인하기 위한 함수를 정의해 두었다.
@Slf4j
public class JwtTokenFutureCallback implements ListenableFutureCallback<SendResult<String, Object>> {
private final Object message;
public JwtTokenFutureCallback(Object message) {
this.message = message;
}
@Override
public void onFailure(Throwable ex) {
LOGGER.debug("Unable to send message=[{}] due to : {}", message, ex.getMessage());
}
@Override
public void onSuccess(SendResult<String, Object> result) {
LOGGER.debug("Sent message=[{}] with offset=[{}]", message, result.getRecordMetadata().offset());
}
}
우선 KafkaTemplate의 경우 Dependency Injection을 통해 Configuration에서 등록된 Bean이 매핑되고, 이 template을 통해
Send() 함수를 호출해서 메세지를 보내준다. 필요한 부분은 Topic과 메세지를 넣는 부분이다. 메세지는 각 메세지의 Object이고, Object를 넣어서 보내면 Configuration에서 설정해 둔 Serializer가 Json String 형태로 변경하여 보내게 된다.
처음에 이 부분을 이해하고 코드를 추가하고 테스트를 하는데 어려움을 겪었다. 양쪽 서비스에 구현을 한 후 테스트를 하면서 문제 부분을 확인 후에 수정을 하다보니 시간이 많이 걸렸다. 처음부터 Embedded kafka를 설정해서 Unit test 만들면서 했으면 더 쉬웠을 것 같다. 하지만, Embedded kafka를 적용한 것도 시간이 걸렸으니 쌤쌤인가? ㅋㅋ
Intellij에서 Java project를 진행하다보면 가끔 @Autowired inspection의 오류가 있는 경우가 있다.
나의 경우는 Spring-kafka-test를 Kafka Unit test를 만들때 발생하였다.
Embedded kafka를 활용하여 Kafka Unit test를 진행하게 되는데 EmbeddedKafkaBroker의 Dependency를 추가하려고 하는데 Intellij 에서 아래와 같이 Inspection 오류를 표시하였다. 빨갛게 표시를 하고 있어서 여간 귀찮은 것이 아니다.
실제 동작은 잘되기 때문에 보이지 않게 무시하고 싶었다.
그래서 @Autowired inspection 표시 등급을 Error에서 Warning으로 변경하여 무시하기로 하였다.
위와 같이 메뉴를 보면 Edit Inspection profile setting 이라는 메뉴가 있고 이곳으로 들어가자.
