# zookeeper ```bash # TODO安装zookeeper集群 ``` # broker ```toml # kafka在启动服务之前必须要设定3个参数:broker.id、log.dirs、zookeeper.connect broker.id=10 log.dirs=/opt/kafka/data/ zookeeper.connect=n183:2181,n184:2181,n185:2181 ``` ```bash ./kafka-server-start.sh -daemon ../config/server.properties ``` ```bash [2019-04-08 20:43:53,886] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$) [2019-04-08 20:43:54,327] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$) java.lang.IllegalArgumentException: requirement failed: broker.id must be equal or greater than -1 and not greater than reserved.broker.max.id at scala.Predef$.require(Predef.scala:281) at kafka.server.KafkaConfig.validateValues(KafkaConfig.scala:1441) at kafka.server.KafkaConfig.(KafkaConfig.scala:1437) at kafka.server.KafkaConfig.(KafkaConfig.scala:1097) at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:1077) at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:28) at kafka.Kafka$.main(Kafka.scala:59) at kafka.Kafka.main(Kafka.scala) [2019-04-08 20:44:44,579] INFO Cluster ID = NPj6E5Z9Tceeiyi6Etpo5Q (kafka.server.KafkaServer) [2019-04-08 20:44:44,584] ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) kafka.common.InconsistentBrokerIdException: Configured broker.id 10 doesn't match stored broker.id 0 in meta.properties. If you moved your data, make sure your configured broker.id matches. If you intend to create a new broker, you should remove all data in your data directories (log.dirs). at kafka.server.KafkaServer.getBrokerIdAndOfflineDirs(KafkaServer.scala:710) at kafka.server.KafkaServer.startup(KafkaServer.scala:212) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38) at kafka.Kafka$.main(Kafka.scala:75) at kafka.Kafka.main(Kafka.scala) ``` ```bash ./bin/kafka-topics.sh --create --zookeeper n183:2181 --replication-factor 1 --partitions 1 --topic test ./bin/kafka-topics.sh --list --zookeeper n183:2181 ./bin/kafka-console-producer.sh --broker-list n199:9092 --topic test ./bin/kafka-console-consumer.sh --bootstrap-server n199:9092 --topic test --from-beginning ``` # ref * [releases](https://kafka.apache.org/downloads)