브로커에 연결이 안됩니다

[아파치 카프카 애플리케이션 프로그래밍] 개념부터 컨슈머, 프로듀서, 커넥트, 스트림즈까지!

카프카 커넥트

작성

617

원영님 강의를 보고 현재 스프링 프레임워크 기반의 회사 솔루션에 카프카 도입을 구현하고 있습니다.

터미널 상에서 컨슈머와 프로듀서는 잘 주고 받는데 IDE로 넘어와 적용하면 에러가 발생합니다

브로커의 로그를 확인해보니

Processing automatic preferred replica leader election (kafka.controller.KafkaController)

Checking need to trigger auto leader balancing (kafka.controller.KafkaController)

Topics not in preferred replica for broker 0 Map() (kafka.controller.KafkaController)

이런 로그들이 찍히는데 구글링해도 이렇다 할 해결방법을 못찾고 있습니다

컨슈머 프로퍼티에 부트스트랩 서버도 localhost:9092

프로듀서 프로퍼티의 부트스트랩 서버도 동일하며

서버 프로퍼티의 애드버타이즈드 리스너도 localhost:9092로 설정해뒀습니다

혹시 제가 빠뜨린 부분이 있을까요? 도움 주시면 감사하겠습니다..

답변 2

지식공유자

환경에 따라 설정이 달라질 수 있기 때문에 정확하게 말씀드리긴 어렵습니다만, 다음 사항들을 확인해보셔도 좋을거 같아요.

server.properties에 listeners를 listeners=PLAINTEXT://localhost:9092로 셋팅 해보세요.
윈도우환경에서는 ipv6가 기본값으로 될 수도 있습니다. 이런 경우에는 다음과 같이 셋팅 해보세요.
- server.properties에 listeners=PLAINTEXT://[::]:9092
- producer 설정에 bootstrap.servers=[::]:9092

안녕하세요, 인프런 AI 인턴이에요.

카프카 도입 과정에서 발생하는 에러는 아이디어가 생각나지 않아 매우 힘들죠. 상세하게 질문 내용을 감사드립니다.

로그를 봤을 때, 브로커(카프카 서버)의 리더 선출 처리 문제가 발생하는 것으로 보이는데요. 이 문제에 대해서는 구글링을 통해서 여러가지 해결 방법이 있지만, 문제 원인에 따라 다를 수 있으므로 디버깅이 필요합니다.

질문 내용에서 확인할 수 있는 설정들은 모두 localhost:9092로 설정해뒀으며, 이 부분에서는 문제가 없어 보입니다. 하지만, 브로커의 설정과 네트워크 상태도 함께 확인해볼 필요가 있습니다.

스프링 프레임워크 기반의 회사 솔루션이라면, 인프런의 스프링 강의나 Q&A 게시판에서도 정확한 답변을 얻을 수 있을 것 같습니다. 혹시 이 과정을 수강하시면 더욱 수월하게 진행할 수 있을 것입니다.

해결책을 찾을 수 있도록 최선을 다해 도와드리겠습니다. 감사합니다.

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