inflearn logo
강의

Khóa học

Chia sẻ kiến thức

[Lập trình ứng dụng Apache Kafka] Từ ý tưởng đến người tiêu dùng, nhà sản xuất, kết nối và truyền phát!

Điều hành một nhà môi giới Kafka tại địa phương

kafka 를 띄우니 오류가 발생하고 종료합니다.

275

scmoon

23 câu hỏi đã được viết

0

kafka 를 띄우니 오류가 발생하고 종료합니다.

무엇을 살펴 봐야 하나요?

 

[2024-12-12 23:29:35,030] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)

kafka.common.InconsistentClusterIdException: The Cluster ID CwTLqMY7QRKRU5AggS5Agw doesn't match stored clusterId Some(NfwQFiB2RUSszayrQc61NA) in meta.properties. The broker is trying to join the wrong cluster. Configured zookeeper.connect may be wrong.

at kafka.server.KafkaServer.startup(KafkaServer.scala:223)

at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:44)

at kafka.Kafka$.main(Kafka.scala:82)

at kafka.Kafka.main(Kafka.scala)

kafka 데이터-엔지니어링

Câu trả lời 3

0

scmoon

data 내 파일들을 삭제하고 재시작 하니 되네요. 감사합니다.

0

dvwy

안녕하세요~ 보내주신 로그를 보니 주키퍼와 설정이 잘못되었거나 버전이 맞지 않는 것으로 보입니다.

  • 현재 다운로드, 실행한 카프카가 2.5.0이 맞는지 확인 부탁드립니다.

  • 주키퍼가 정상적으로 실행중인지 확인 부탁드립니다.

0

communityai8509

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

moonseok.shin님께서 겪고 계신 InconsistentClusterIdException 오류는 Kafka 클러스터의 ID가 서로 일치하지 않아서 발생하는 문제입니다. 이는 Kafka 브로커가 잘못된 클러스터에 연결되어 있다고 인식할 때 나타납니다. 다음은 이 문제를 해결하기 위한 몇 가지 단계입니다:

  1. meta.properties 파일 확인 및 삭제:

    • 해당 오류 메시지에 언급된 meta.properties 파일에서 저장된 클러스터 ID가 현재 사용 중인 클러스터 ID와 일치하지 않습니다. 이 파일은 일반적으로 Kafka의 데이터 디렉토리에 저장됩니다.
    • meta.properties 파일을 삭제하고 Kafka 브로커를 다시 시작하여 새로운 클러스터 ID로 초기화하도록 할 수 있습니다. 하지만 이 작업은 데이터 손실을 초래할 수 있으므로 주의가 필요합니다.
  2. zookeeper.connect 설정 확인:

    • 설정 파일의 zookeeper.connect 항목을 확인하여 올바른 ZooKeeper 서버 주소가 설정되어 있는지 확인하세요. 잘못된 ZooKeeper 설정은 클러스터 ID 불일치를 유발할 수 있습니다.
  3. Kafka 프로세스 정리:

    • 백그라운드에서 실행 중인 이전 Kafka 프로세스가 있다면, 이를 완전히 종료한 후 다시 시작해 보세요.

이와 관련한 유사한 질문과 답변은 아래에서 확인하실 수 있습니다:
- 카프카 클러스터 ID 충돌 이슈가 있습니다.

이 글을 참조하여 문제를 해결하시길 바랍니다.

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

consume 이후 lag가 줄어들지 않음

0

65

2

안녕하세요. 강의의 카프카 버전과 현재 시점의 카프카의 차이점 문의 드립니다.

0

93

2

멱등성 프로듀서 retries 관련 질문입니다.

0

93

2

채팅 서비스 개발 시 주의점이 있을까요?

0

94

2

충분히 큰 파티션 생성시 궁금증이 존재합니다.

0

81

2

KTable 키가 없는 레코드 처리

0

69

2

컨슈머 테스트 코드 작성

0

90

2

리밸런스 onPartitionRevoked이 필요한 상황

0

72

2

카프카 클러스터에서 감당 가능한 파티션(레플리카) 수 문의

0

115

2

reset offset 질문

0

72

2

KStreamJoinKTable 실행시 오류

0

74

2

auto.commit.interval.ms 옵션 관련 질문 드립니다.

0

134

2

파티션, 컨슈머 그룹, 컨슈머 관련 질문

0

114

1

java, kotlin

0

126

2

shutdownThread 에 대한 문의 입니다.

0

149

2

zookeeper실행시 오류가 발생합니다.

0

264

2

커스텀 소스 커넥터에서 Thread.sleep (1000) 은 왜 하는거에요?

0

149

2

처리량을 늘리기 위해서 파티션을 늘리고 컨슈머를 늘려야한다고 설명하셨는데요

0

178

3

파티션 개수와 컨슈머 개수의 처리량 관련 질문

0

160

2

동영상 및 이미지 처리 관련 문의 드립니다.

0

219

2

주키퍼 없이 사용 문의 드립니다.

0

289

1

zookeeper 실행시 오류 .. 무엇을 해야 할까요?

0

214

2

파티션 추가로 해결할 수 있지만 늘어난 파티션은 줄일 수 없지 않나요?

0

189

2

카프카 2.8.2 버전과 많이 차이가 있을까요??.

0

158

2