Skip to content

kafka base

Jump to bottom
lanzhiwang edited this page Oct 6, 2018 · 1 revision

Kafka 基础

安装

要求:

  1. Java
  2. Zookeeper
# tar -zxvf kafka_2.11-0.9.0.1.tgz
# mv kafka_2.11-0.9.0.1 /usr/local/kafka
# mkdir /tmp/kafka-logs
# export JAVA_HOME=/usr/java/jdkl.8.0_51
# /usr/local/kafka/bin/kafka-server-start.sh -daemon
/usr/local/kafka/config/server.properties
#

常规配置

  1. broker.id
  2. port
  3. zookeeper.connect
  4. log.dirs
  5. num.recovery.threads.per.data.dir
  6. auto.create.topics.enable

集群

要把一个 broker 加入到集群里，只需要修改两个配置参数。首先，所有 broker 都必须配置相同的 zookeeper.connect， 该参数指定了用于保存元数据的 Zookeeper 群组和路径。其次，每个 broker 都必须为 broker.id 参数设置唯一的值。 如果两个 broker 使用相同的 broker.id，那么第二个 broker 就无法启动。在运行集群时，还可以配置其他一些参数，特别是那些用于控制数据复制的参数。

Clone this wiki locally