inflearn logo
강의

강의

N
챌린지

챌린지

멘토링

멘토링

N
클립

클립

로드맵

로드맵

지식공유

묻고 답해요

172만명의 커뮤니티!! 함께 토론해봐요.

섹션7 51 컨슈머서버 무한 리로드?

미해결

실전에서 바로 써먹는 Kafka 입문

이전에 컨슈머 서버 ( email-send-consumer ) 에서는 문제가없었는데 마지막 email-service에서는 2025-08-28T23:50:12.394+09:00 INFO 40252 --- [ner#0.dlt-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-29, groupId=email-service.dlt] Discovered group coordinator 13.209.11.23:9092 (id: 2147483646 rack: null) 2025-08-28T23:50:12.394+09:00 INFO 40252 --- [ner#0.dlt-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-29, groupId=email-service.dlt] Request joining group due to: rebalance failed due to 'The coordinator is not available.' (CoordinatorNotAvailableException) 2025-08-28T23:50:12.396+09:00 INFO 40252 --- [ner#0.dlt-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-31, groupId=email-service.dlt] Discovered group coordinator 13.209.11.23:9092 (id: 2147483646 rack: null) 2025-08-28T23:50:12.396+09:00 INFO 40252 --- [ner#0.dlt-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-30, groupId=email-service.dlt] (Re-)joining group 2025-08-28T23:50:12.396+09:00 INFO 40252 --- [ner#0.dlt-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-31, groupId=email-service.dlt] Request joining group due to: rebalance failed due to 'The coordinator is not available.' (CoordinatorNotAvailableException) 2025-08-28T23:50:12.399+09:00 INFO 40252 --- [ner#0.dlt-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-29, groupId=email-service.dlt] (Re-)joining group 2025-08-28T23:50:12.401+09:00 INFO 40252 --- [ner#0.dlt-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-31, groupId=email-service.dlt] (Re-)joining group 2025-08-28T23:50:12.411+09:00 INFO 40252 --- [ner#0.dlt-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-30, groupId=email-service.dlt] Successfully joined group with generation Generation{generationId=261, memberId='consumer-email-service.dlt-30-5a032e9e-a903-4fb7-9004-487d74eb6c79', protocol='range'} 2025-08-28T23:50:12.411+09:00 INFO 40252 --- [ner#0.dlt-2-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-31, groupId=email-service.dlt] Successfully joined group with generation Generation{generationId=261, memberId='consumer-email-service.dlt-31-0cdcda6c-6ddf-4e0b-980a-868f587ed2bd', protocol='range'} 2025-08-28T23:50:12.411+09:00 INFO 40252 --- [ner#0.dlt-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-29, groupId=email-service.dlt] Successfully joined group with generation Generation{generationId=261, memberId='consumer-email-service.dlt-29-2b16177f-2cc3-44c0-b244-50109078218e', protocol='range'} 2025-08-28T23:50:12.411+09:00 INFO 40252 --- [ner#0.dlt-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-email-service.dlt-30, groupId=email-service.dlt] Finished assignment for group at generation 261: {consumer-email-service.dlt-31-0cdcda6c-6ddf-4e0b-980a-868f587ed2bd=Assignment(partitions=[]), consumer-email-service.dlt-29-2b16177f-2cc3-44c0-b244-50109078218e=Assignment(partitions=[user.signed-up.dlt-0]), consumer-email-service.dlt-30-5a032e9e-a903-4fb7-9004-487d74eb6c79=Assignment(partitions=[])} ... 이런식으로 계속 로그가 반복됩니다 프로듀서에 발행은 완료됐고 cli에서 메세지도 확인했는데 컨슈머서버에서 저렇게 자꾸 정상적으로 작동을 하지않습니다 @Service public class UserSignedUpEventConsumer { private final EmailLogRepository emailLogRepository; public UserSignedUpEventConsumer(EmailLogRepository emailLogRepository) { this.emailLogRepository = emailLogRepository; } @KafkaListener( topics = "user.signed-up", groupId = "email-service", concurrency = "3" ) @RetryableTopic( attempts = "5", backoff = @Backoff(delay = 1000, multiplier = 2), // 1 초 2초 4초 8초 16초 5번 dltTopicSuffix = ".dlt" ) public void consume(String message) throws InterruptedException { UserSignedUpEvent userSignedUpEvent = UserSignedUpEvent.fromJson(message); // 실제 이메일 발송 로직 String receiverEmail = userSignedUpEvent.getEmail(); String subject = userSignedUpEvent.getName() + "님 회원가입 ㅊㅋ"; Thread.sleep(3000); System.out.println("메일 발송 완료"); // 이메일 발송 로그 저장 EmailLog emailLog = new EmailLog(userSignedUpEvent.getUserId(), receiverEmail, subject); emailLogRepository.save(emailLog); } 강사님 코드랑 이전 email-send-consumer 서비스 코드 및 야믈파일도 몇번 확인했는데 다른점이 없습니다 왜그런걸까요

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
나마스테 댓글 4 좋아요 0 조회수 183

섹션6 43 질문드립니다

미해결

실전에서 바로 써먹는 Kafka 입문

안녕하세요, 강의 잘보고있습니다. 프로듀서나 컨슈머서버 야믈파일에서 3개의 ip를 적고있는데 만약 컨슈머 서버를 2대이상 돌렸을때 기준으로 각 서비스마다 ip를 똑같이 3개 적어야하는건가요? 아니면 1번 서버에서는 리더 노드ip 만 2번 서버에서는 팔로워 파티션 노드 ip 만 이런식으로 나눠서 적용하나요? 또 저런식으로 서버가 나눠져있는경우 순차적으로 메세지 처리는 이전에 강의에서 언급한 하나의 파티션은 단 하나의 컨슈머에만 할당되고 컨슈머는 메세지를 순서대로 처리한다했는데 순서에는 상관이 없는걸까요? 추가로 그다음 섹션보다가 궁금한게 현업에서도 라운드로빈방식을 대부분 사용하나요? 실무기준에서 궁금합니다!

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
나마스테 댓글 3 좋아요 0 조회수 82

vm 실행 후 rocky linux 초기 세팅 화면이 안나옴

미해결

대세는 쿠버네티스 (초급~중급편)

kubernetes cluster 설치 - mac 과정 중 3-3) 생성된 vm 실행 후 rocky linux 초기 세팅 과정에서 Install Rocky Linux 메뉴가 나오지 않고 이러한 화면이 나옵니다. 강의 메뉴얼 대로 진행하려면 어떻게 해야할까요? 네트워크 설정까지는 동일하게 진행 했습니다!

  • docker
  • kubernetes
  • devops
  • container
송석준 댓글 2 좋아요 1 조회수 340

Operator / CRD 을 강의에서 다루는지 궁금합니다.

미해결

대세는 쿠버네티스 (초급~중급편)

안녕하세요. 강사님 카프카를 K8S에 설치할 때 Operator / CRD 라는 개념이 나오는데요. 위 개념은 강사님 전체 로드맵중에서 어떤 강의에 등장하는지 알 수 있을까요?

  • docker
  • kubernetes
  • devops
  • container
창신동 장첸 댓글 2 좋아요 1 조회수 68

섹션8 강의자료 중 설명하지 않은 내용 질문

미해결

대세는 쿠버네티스 (초급~중급편)

섹션 6.[중급편] 기본 오브젝트 - 인프런 위 강의자료 p.13에서의 내용은 강의에서 설명을 합니다. p.14를 끝으로 강의가 종료되는데요. p.15를 보면 p.13과 매우 비슷한 그림을 갖으나 link부분이 Kubelet에서 WorkerNode로 향하는 화살이 추가로 보입니다. 어떤 것을 설명하시려고 장표를 넣으신 것인지 궁금합니다~

  • docker
  • kubernetes
  • devops
  • container
창신동 장첸 댓글 1 좋아요 1 조회수 68

replicaset을 delete할 때 cascade 영향을 받는 Pod들

미해결

대세는 쿠버네티스 (초급~중급편)

안녕하세요 선생님, 먼저 세심한 실습환경을 안내해주신 덕분에 강의를 재밌게 듣고 있습니다. 감사합니다. 카페에 아래와 같은 글을 남기셨습니다. https://cafe.naver.com/kubeops/503 ▶ Pod만 남기고 Controller(ReplicaSet)만 삭제하는 방법 kubectl delete replicaset replica1 --cascade=orphan * Pod를 직접만들고 Controller에 수동으로 연결했을 때만 동작해요. 그래서 직접 실습을 진행해봤습니다. Pod : 직접생성 ReplicaSet : 직접생성 및 위 Pod와 수동연결 위 순서대로 진행하면 아래와 같은 Pod상황이 만들어집니다. 위 상황에서 delete cascade옵션 명령어를 수행했을 때 두 Pod모두 살아있는 것을 확인했는데요. 카페에 남기신 글은 pod1만 살아남는다고 설명을 하신것 같은데 제가 잘못해석했는지 궁금합니다~

  • docker
  • kubernetes
  • devops
  • container
창신동 장첸 댓글 2 좋아요 1 조회수 76

kafka [37강의]

미해결

실전에서 바로 써먹는 Kafka 입문

[1] 기존 Kafka 프로세스 확인 및 종료 [2] 포트 사용 여부 확인 [3] 깔끔하게 다시 시작 bin/ kafka-server-start.sh config/ server.properties 같은 에러가 뜹니다. 에러 원인을 확인하기가 힘드네요 ㅠ

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
익명리 댓글 2 좋아요 0 조회수 95

섹션6. 36,37

미해결

실전에서 바로 써먹는 Kafka 입문

섹션6. 36,37 강의를 실습하고 다음날 다시 bin/ kafka-server-start.sh config/ server.properties 명령어 써서 실행시키려니까 이렇게 뜨고 실행이 안됩니다. 원인이 뭘까요?

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
익명리 댓글 2 좋아요 1 조회수 90

실무 관점에서

미해결

쿠버네티스 어나더 클래스-Sprint3 (#실무핵심 #Docker #Nginx #Minio #Longhorn)

안녕하세요. 이제 sprint1 을 통해 기본적인 개념정도만 습득한 상태입니다. spring boot 애플리케이션 -> K8s 배포를 기준으로 실제 앱 내에서 사용되는 환경변수 설정과 K8s내의 컨피그맵, 시크릿 등에 대한 설정 매칭 등을 보고 싶은데 sprint 1 -> 지금 강의를 먼저 수강 해도 이해가 괜찮을까요? [ 👍 좋은 질문을 했을 때 좋은 답변이 돌아 옵니다] 1. 실습 중 본인의 환경이 가이드와 다른 부분이 있었다면 말씀해주세요. 2. 해당 문제의 발생 빈도(재설치 여부)와 문제 해결을 위해 시도해본 케이스를 말씀해 주시면 원인 파악에 큰 도움이 됩니다. 3. 에러 메시지만 봐서는 저도 모르는 경우가 많아요. 그전에 했던 작업이 포함된 캡쳐 화면도 부탁 드려요. 4. 영상 내용에 대한 질문 시 해당 시간을 같이 올려 주시면 답변을 드리는 시간이 더 빨라집니다. 5. 긴 로그는 제 메일로 보내주세요. ( k8s.1pro@gmail.com ) 6. 카페 [ 강의 자료실 ]에도 많은 질문과 답변들이 있어요!

  • 네트워크
  • kubernetes
  • devops
  • infrastructure
  • container
안승현 댓글 1 좋아요 1 조회수 82

K8s 대시보드의 신규 리소스 생성시 이슈

미해결

쿠버네티스 어나더 클래스-Sprint 1, 2 (#실무기초 #설치 #배포 #Jenkins #Helm #ArgoCD)

대시보드에서 복사해서 내용 넣었을 때 해당과 같은 이슈가 발생하시는 분들 계시면.. vi 로 yaml 하나 만들어서 붙여넣은 뒤에 chmod +x ~.yaml k apply -f ~.yaml 하니까 가능합니다. 혹시 헷갈리시는 분들 참고!!!...

  • kubernetes
  • devops
  • argocd
  • container
  • helm
안승현 댓글 2 좋아요 1 조회수 79

모든 컨테이너가 running 중이나 그라파나에 나타나지않음

미해결

쿠버네티스 어나더 클래스-Sprint 1, 2 (#실무기초 #설치 #배포 #Jenkins #Helm #ArgoCD)

왜이럴까요 +수정 확인해보니 로키가 라벨을 수집 못하고있다고합니다 +수정 systemctl restart chronyd.service 통해서 explore -> loki -> label browser 확인결과 파드로 떠진것들 중 default namespace 의 app만 나타나지 않습니다. +Explore에는 안뜨지만 dashboard namespace의 default를 통하여 확인 및 해결 완료하였습니다.

  • kubernetes
  • devops
  • argocd
  • container
  • helm
안승현 댓글 1 좋아요 1 조회수 96

데시보드에서 파드 생성 안됨

미해결

대세는 쿠버네티스 (초급~중급편)

생성이 안되는데 어떤 문제인가요

  • docker
  • kubernetes
  • devops
  • container
이민호 댓글 2 좋아요 1 조회수 97

msa 강좌 관련해서 질문 있어서 글 남깁니다!

미해결

실전에서 바로 써먹는 Kafka 입문

안녕하세요! 수업 정말 잘 듣고 있는 수강생입니다!! 다름이 아니라 msa 강좌 일정 관련해서 언제쯤 나오는지 궁금해서 글 남깁니다! (어디에 질문 남길지 고민하다가 그냥 여기에 남겼어요..ㅠㅠ)

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
김준성 댓글 2 좋아요 0 조회수 92

정말 사소한 질문이지만 ... 궁금해서 물어봅니다.

미해결

실전에서 바로 써먹는 Elasticsearch 입문 (검색 최적화편)

안녕하세요... 정말 사소한 질문이지만... controller 를 만들때 @GetMapping() 이런식으로 () 빈 괄호를 쓰시던데 혹시 특별한 이유가 있을까요 ???? 뭔가 가독성이 좋다거나...?? 이런 스타일은 첨봐서 신기해서 문의드립니다 !

  • spring-boot
  • elasticsearch
  • devops
  • elk
  • infrastructure
HJ 댓글 1 좋아요 0 조회수 111

컨테이너로 노드를 구성해도 될까요?

미해결

쿠버네티스 어나더 클래스-Sprint 1, 2 (#실무기초 #설치 #배포 #Jenkins #Helm #ArgoCD)

가상 머신으로 서버 몇개 돌리면 컴퓨터가 정신을 못 차립니다. ㅠㅠ [ 👍 좋은 질문을 했을 때 좋은 답변이 돌아 옵니다] 1. 실습 중 본인의 환경이 가이드와 다른 부분이 있었다면 말씀해주세요. 2. 해당 문제의 발생 빈도(재설치 여부)와 문제 해결을 위해 시도해본 케이스를 말씀해 주시면 원인 파악에 큰 도움이 됩니다. 3. 에러 메시지만 봐서는 저도 모르는 경우가 많아요. 그전에 했던 작업이 포함된 캡쳐 화면도 부탁 드려요. 4. 영상 내용에 대한 질문 시 해당 시간을 같이 올려 주시면 답변을 드리는 시간이 더 빨라집니다. 5. 긴 로그는 제 메일로 보내주세요. ( k8s.1pro@gmail.com ) 6. 카페 [ 강의 자료실 ]에도 많은 질문과 답변들이 있어요!

  • kubernetes
  • devops
  • argocd
  • container
  • helm
cat 댓글 2 좋아요 1 조회수 78

Kafka concurrency

미해결

실전에서 바로 써먹는 Kafka 입문

안녕하세요, Consumer 서버가 2대라고 가정해보겠습니다. @KafkaListener의 concurrency 값을 설정을 2으로 설정하였다고 가정한다면, 2개의 스레드가 생성이돼서 병렬적으로 파티션을 처리할텐데 위의 설정 없이 그냥 @KafkaListener가 붙은 메서드에 @Async를 통해서 ThreadPool의 크기를 2으로 설정하였다면, 동일하게 동작하게 되는걸까요? 스프링 MVC의 경우 톰캣 기본 설정이 200 정도의 스레드풀을 할당해서 병렬적으로 처리하는 것으로 알고 있는데, Async대신 KafkaListener의 concurrency 설정을 200으로 하는 것이 맞을까요?

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
댓글 3 좋아요 0 조회수 195

Kafka timeout 설정

미해결

실전에서 바로 써먹는 Kafka 입문

안녕하세요. 보통 RestTemplate, WebClient, FeignClient 등으로 외부 요청 등을 시도할 경우에는 timeout 설정을 중요하게 생각하는데, 카프카에서는 Connection Timeout, Read Timeout 등과 같은 셋팅 값을 몇 초로 설정해야할까요? 그리고 몇 초에 해당하는 값을 정하는 기준이 어떻게 될까요?

  • kafka
  • EDA
  • msa
  • devops
  • infrastructure
강토토 댓글 2 좋아요 0 조회수 230

맥 m3 쿠버네티스 클러스터 설치오류

미해결

대세는 쿠버네티스 (초급~중급편)

[ 👍 좋은 질문을 했을 때 좋은 답변이 돌아 옵니다] 1. 실습 중 본인의 환경이 가이드와 다른 부분이 있었다면 말씀해주세요. 2. 해당 문제의 발생 빈도(재설치 여부)와 문제 해결을 위해 시도해본 케이스를 말씀해 주시면 원인 파악에 큰 도움이 됩니다. 3. 에러 메시지만 봐서는 저도 모르는 경우가 많아요. 그전에 했던 작업이 포함된 캡쳐 화면도 부탁 드려요. 4. 영상 내용에 대한 질문 시 해당 시간을 같이 올려 주시면 답변을 드리는 시간이 더 빨라집니다. 5. 긴 로그는 제 메일로 보내주세요. ( k8s.1pro@gmail.com ) 강사님의 깃헙 참고하여 맥 m시리즈 가이드를 보고 쿠버네티스 클러스터 설치 부분을 따라하고 있는데 Rocky와 UTM 연동이 안되는 것 같습니다. 권한 문제일 수 있다고 해서 터미널에서 권한 추가했는데도 안되네요. 재생버튼을 누르면 터미널이 한 1초 떴다가 다시 저 화면으로 돌아갑니다. 아무런 오류 메시지도 없습니다. 해결하는 방법이 있을까요?

  • docker
  • kubernetes
  • devops
  • container
hahahello777 댓글 2 좋아요 1 조회수 103

레디스에 저장하는 토큰 질문입니다.

미해결

개발자라면 알아야 할 redis 기본

안녕하세요. 토큰 관련해서 레디스에 저장하는 게 리프레시 토큰이라고 하셨는데요. 액세스 토큰을 저장 안 하는 건지 궁금합니다. 리프레시 토큰은 액세스 토큰이 만료될 떄 필요하니까 상대적으로 사용 빈도가 낮고 매 요청 시에는 액세스 토큰이 쓰이는 걸로 알고 있어서요. 그렇다면 수시로 검증해야 하는 토큰은 액세스 토큰이 아닐까 해서요. 감사합니다.

  • redis
  • nosql
  • database
  • devops
literate_t 댓글 2 좋아요 0 조회수 95

인기 태그

인프런 TOP Writers

주간 인기글