Spring Boot는 Kafka의 토픽 또는 GroupId를 동적으로 설정합니다

작은 쓰레기 같은 놈들 · 게시됨 2021. 11. 14. 오후 8:03:45

클러스터에 마이크로서비스를 배포할 때, 모든 애플리케이션에 명령을 내리고 싶다면 Kafka 주제에 애플리케이션을 구독할 수 있지만, 동일한 주제가 모든 애플리케이션에 수신되려면 서로 다른 그룹ID를 설정해야 한다는 점을 유의해야 합니다.

도커를 사용해 다음 명령어로 Kafka 애플리케이션을 구축하세요:

로그인이 보이네요.

참고: 192.168.1.166을 실제 IP 주소로 교체하세요

pom.xml spring-kafka 패키지를 다음과 같이 소개합니다:

로그인이 보이네요.

Kafka 소비자 구성을 맞춤화하려면 다음과 같이 새로운 KafkaConsumer 파일을 생성하세요:

로그인이 보이네요.

기본 구성이 있는 새로운 소비자 ConfigConsumer를 생성하는데, 이 구성은 topic:defaultTopic,groupid:defaultGroupId이며, 코드는 다음과 같습니다:

로그인이 보이네요.

application.properties를 사용하여 카프카의 주소를 구성합니다:

로그인이 보이네요.

프로젝트를 시작하려면 앱 구독이 기본 구성으로 사용되며, 다음과 같습니다:

KafkaMessageListenerContainer는 AbstractMessageListenerContainer 추상 클래스를 상속하며, createSimpleLoggingConsumerRebalanceListen 메서드는 소비자의 groupid와 주제 partition을 출력합니다.

2021-11-14 19:44:26.689 정보 14256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : defaultGroupId: partitions assigned: [defaultTopic-0]

주제와 그룹ID를 동적으로 설정하면 프로젝트 시작 명령은 다음과 같습니다:

로그인이 보이네요.

주제는 a1로 설정되어 있고 그룹ID는 itsvse.com

2021-11-14 19:46:25.330 정보 12256 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : itsvse.com: 할당된 파티션: [a1-0]

Spring은 jar 패키지 내 기본 구성을 덮어씁니다
https://www.itsvse.com/thread-10129-1-1.html

(끝)

[출처] Spring Boot는 Kafka의 토픽 또는 GroupId를 동적으로 설정합니다

관련 게시물

본 섹션