메뉴 건너뛰기

검색창 닫기

Cloudera, BigData, Semantic IoT, Hadoop, NoSQL

Cloudera CDH/CDP 및 Hadoop EcoSystem, Semantic IoT등의 개발/운영 기술을 정리합니다. gooper@gooper.com로 문의 주세요.


kafka kafka broker기동시 brokerId가 달라서 기동에 실패하는 경우 조치방법

총관리자 2016.05.02 15:42 조회 수 : 2420

아래와 같이 meta.properties파일에 있는 brokerId가 실행시 사용된 config파일과 달라서 기동에 실패하는 경우는

logs파일 위치(예, "/logs/kafka/kafka-logs/meta.properties")에 있는 meta.properties파일을 열어서 broker.id를 수정하고 저장한다.



--------------------------------------------------------오류내용----------------------------------

[2016-05-02 15:32:06,302] FATAL Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
kafka.common.InconsistentBrokerIdException: Configured brokerId 2 doesn't match stored brokerId 1 in meta.properties
        at kafka.server.KafkaServer.getBrokerId(KafkaServer.scala:630)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:175)
        at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
        at kafka.Kafka$.main(Kafka.scala:67)
        at kafka.Kafka.main(Kafka.scala)
[2016-05-02 15:32:06,303] INFO shutting down (kafka.server.KafkaServer)
[2016-05-02 15:32:06,305] INFO Shutting down. (kafka.log.LogManager)
[2016-05-02 15:32:06,310] INFO Shutdown complete. (kafka.log.LogManager)
[2016-05-02 15:32:06,310] INFO Terminate ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
[2016-05-02 15:32:06,312] INFO Session: 0x15432cb047e0058 closed (org.apache.zookeeper.ZooKeeper)
[2016-05-02 15:32:06,312] INFO EventThread shut down (org.apache.zookeeper.ClientCnxn)
[2016-05-02 15:32:06,313] INFO shut down completed (kafka.server.KafkaServer)
[2016-05-02 15:32:06,313] FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
kafka.common.InconsistentBrokerIdException: Configured brokerId 2 doesn't match stored brokerId 1 in meta.properties
        at kafka.server.KafkaServer.getBrokerId(KafkaServer.scala:630)
        at kafka.server.KafkaServer.startup(KafkaServer.scala:175)
        at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
        at kafka.Kafka$.main(Kafka.scala:67)
        at kafka.Kafka.main(Kafka.scala)
[2016-05-02 15:32:06,314] INFO shutting down (kafka.server.KafkaServer)

이 게시물을
이 글의 추천인 목록 목록
번호 제목 날짜 조회 수
120 "Initial job has not accepted any resources; check your cluster UI to ensure that workers are registered and have sufficient resources"오류 발생시 조치사항 2016.05.25 1134
119 spark-env.sh에서 사용할 수있는 항목. 2016.05.24 860
118 Spark 1.6.1 설치후 HA구성 2016.05.24 734
117 spark-shell실행시 "A read-only user or a user in a read-only database is not permitted to disable read-only mode on a connection."오류가 발생하는 경우 해결방법 2016.05.20 627
116 Master rejected startup because clock is out of sync 오류 해결방법 2016.05.03 152
» kafka broker기동시 brokerId가 달라서 기동에 실패하는 경우 조치방법 2016.05.02 2420
114 kafka 0.9.0.1 for scala 2.1.1 설치및 테스트 2016.05.02 570
113 Spark 2.1.1 clustering(5대) 설치(YARN기반) 2016.04.22 2058
112 Hadoop 완벽 가이드 정리된 링크 2016.04.19 454
111 bin/cassandra -f -R로 startup할때 NullPointerException오류가 나면 조치할 내용 2016.04.14 244
110 Cassandra 3.4(3.10) 설치/설정 (5대로 clustering) 2016.04.11 605
109 Incompatible clusterIDs오류 원인및 해결방법 2016.04.01 577
108 namenode오류 복구시 사용하는 명령 2016.04.01 489
107 "java.net.NoRouteToHostException: 호스트로 갈 루트가 없음" 오류시 확인및 조치할 사항 2016.04.01 3223
106 CentOS의 서버 5대에 yarn(hadoop 2.7.2)설치하기-ResourceManager HA/HDFS HA포함, JobHistory포함 2016.03.29 1199
105 Spark Streaming으로 유실 없는 스트림 처리 인프라 구축하기 2016.03.11 263
104 CDH 5.4.4 버전에서 hive on tez (0.7.0)설치하기 2016.01.14 299
103 mongodb에서 큰데이타 sort시 오류발생에 대한 해결방법 2015.12.22 513
102 console명령과 API비교 2015.12.21 484
101 DB별 JDBC 드라이버 2015.10.02 467
쓰기 태그
위로