inflearn logo
강의

講義

知識共有

銀行サーバープロジェクト実習を通じて学ぶKotlinマスタークラス

Kafka Consumer Config の設定 - 1

카프카 컨슈머 구현 질문

解決済みの質問

154

daniel

投稿した質問数 58

0

카프카 스프링을 구현하실 때, @KafkaListener

를 따로 안 사용하시는 이유가 있으신가요?
https://inf.run/cuNfG

kotlin mysql mongodb kafka redis

回答 2

0

Hong

안녕하세요 질문 주셔서 감사합니다.
결론부터 말씀드리자면 딱히 이유는 없습니다.

 

저런 어노테이션을 활용하는것이 당연히 생상선ㅇ을 위해서 더 좋은 형태겠지만, 이건 어디까지나 강의이기 때문에 어노테이션을 최소화하는것이 어떨까라는 생각으로 진행을 하였습니다.

 

보다 좀 더 Raw한 코드를 작성하며 보시는 분들이 코드를 작성하는데에 좀 더 익숙해질 수 있게 구성하고 싶어습니다.

  • 여담으로 저의 개인적인 생각일수도 있지만, 어노테이션을 활용한다는것이 사실 해당 어노테이션에 종속되어 기능이 구현될 수 밖에 없다는 생각도 있어서요.

  • 실제 실무에서는 아무래도 다양한 상황을 마주해야하는 부분도 있어서 따로 어노테이션을 적용하지는 않았습니다.

감사합니다!

0

communityai8509

안녕하세요, 인프런 AI 인턴입니다. yuki님.

Kafka의 소비자(Consumer)를 구현할 때 @KafkaListener 어노테이션을 사용하지 않으신 이유에 대해 궁금해 하시는군요. 이 주제와 관련된 유사한 질문들을 몇 가지 찾아보았습니다.

  1. @KafkaListener를 사용하지 않는 이유:

    • Kafka에서 @KafkaListener 사용: @KafkaListener는 스프링에서 Kafka 메시지를 쉽게 소비할 수 있게 도와주는 어노테이션입니다. 그러나 특정 프로젝트에서 사용하지 않는 이유는 상황에 따라 다릅니다. 예를 들어, 보다 세밀한 컨트롤이 필요하거나, 전통적인 방식의 메시지 소비자 패턴을 선호하는 경우 등입니다. 어떤 경우에는 직접 KafkaConsumer를 구현하여 커스터마이징된 로직을 사용할 수도 있습니다.
  2. Kafka와 스프링의 통합 방식:

    • 스프링과 Kafka 통합: Kafka를 사용할 때, 스프링의 다른 방법으로 통합할 수 있습니다. 프로젝트의 요구사항에 따라 어떤 접근법이 더 적합할지 결정하게 됩니다. 예를 들어, 많은 수의 메시지를 처리하거나, 메시지의 순서 또는 정확한 재처리가 중요할 때, @KafkaListener를 사용하는 것보다 다른 방법이 더 효율적일 수 있습니다.

이처럼 Kafka를 활용할 때 특정 어노테이션이나 방법을 선택하는 데는 프로젝트의 요구사항과 개발자의 선호가 반영될 수 있음을 이해하시면 좋을 것 같습니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다. 현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏 추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

라이브 운영중인 환경의 테이블에 인덱스 추가시 고려사항

0

26

2

강의가 검은 화면으로 나옵니다.

0

44

1

질문] 에러처리 관련 문의

0

70

2

강의_34] 공통 모듈 관련 질문입니다.

0

83

2

강의 19] 질문입니다.

0

62

2

OkHttpClientConfig timeout 설정 질문

0

64

2

Kotlin data class 엔티티에서 copy로 수정 후 save하는 이유가 있을까요?

0

92

2

JDK 선택할 때 궁금점!!

0

107

3

혹시 어플리케이션을 실행할 수 있게 readme 같은건 따로 없나요?

0

82

1

access_token Db 저장건

0

82

2

data class 관련 질문입니다

0

79

2

TransactionMessage 질문

0

53

2

CompletableFuture 질문

0

85

3

스프링 빈 질문

1

87

2

redisConfig 질문입니다

0

107

1

SpringBoot + Kotlin에서 Redis 캐싱 사용 관련되서 여쭤봐도 될까요?

0

243

2

entity 객체 생성을 data class 로 하신 이유가 있을까요?

0

332

3

return@logFor을 사용한 이유가 궁금합니다.

0

139

1

@Transactional.kt에 대한 효용성 질문

0

125

1

@Transactional.kt에 대한 효용성 질문

0

195

1

class 가 아닌 파일로 생성하시는이유

0

188

2

DDL문 정리되어 있는 파일 있을까요?

0

212

2

와 이리 게시판이 조용하노

0

193

1

기기 관련 질문입니다!

0

218

2