KAFKA配置手顺
kafka：192.168.250.10,192.168.250.11,192.168.250.12
zookeeper：192.168.250.10,192.168.250.11,192.168.250.12
1、配置kafka（三个节点设置）
（1）设置环境变量 vi ~/.bashrc (Xms：初始内存，Xmx：最大内存)
export KAFKA_HOME=/opt/software/kafka
export KAFKA_HEAP_OPTS="-Xmx4G -Xms4G -XX:PermSize=64m -XX:MaxPermSize=128m -XX:SurvivorRatio=6 -XX:CMSInitiatingOccupancyFraction=70 -XX:+UseCMSInitiatingOccupancyOnly"
（2）使环境生效
source ~/.bashrc
（3）添加zookeeper信息（三个节点设置）
vi $KAFKA_HOME/config/zookeeper.properties 添加以下信息
maxClientCnxns=0
dataDir=/opt/software/zookeeper-3.4.6/data
dataLogDir=/opt/software/zookeeper-3.4.6/log
clientPort=2181
maxClientCnxns=100
tickTime=2000
initLimit=10
syncLimit=5
server.1=192.168.250.10:2888:3888
server.2=192.168.250.11:2888:3888
server.3=192.168.250.12:2888:3888
（4）配置kafka集群（三个节点设置）
vi $KAFKA_HOME/config/server.properties
broker.id=0 （每个节点要有不同的broker id，分别设置为0,1,2）
delete.topic.enable=true （允许管理人员删除topic）
auto.create.topics.enable=false （手动控制topic的创建，否则goldengate可以自动创建topic）
listeners=PLAINTEXT://192.168.250.10:9092 （配置为本节点的ip）
log.dirs=/usr/local/kafka/var/kafka-logs
zookeeper.connect=192.168.250.10:2181,192.168.250.11:2181,192.168.250.12:2181 （配置所有zookeeper服务器的ip，注意逗号之间不要有空格）
2、配置zookeeper（三个节点设置）
（1）解压tar -xvf zookeeper-3.4.6.tar.gz
（2）export ZOOK_HOME=/opt/software/zookeeper-3.4.6
（3）mkdir $ZOOK_HOME/data
（4）mkdir $ZOOK_HOME/log
（5）vi $ZOOK_HOME/data/myid //每个节点的数值不同，依次增加即可（1,2,3）
3、启动zookeeper
nohup $KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties >$KAFKA_HOME/logs/zk.log &
4、启动kafka
nohup $KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties >$KAFKA_HOME/logs/kk.log &
5、测试kafka
（1）创建topic
$KAFKA_HOME/bin/kafka-topics.sh --create --partitions 1 --replication-factor 3 --zookeeper 192.168.250.10:2181,192.168.250.11:2181,192.168.250.12:2181 --topic oggtopic
（2）检查topic
$KAFKA_HOME/bin/kafka-topics.sh --list --zookeeper 192.168.250.10:2181,192.168.250.11:2181,192.168.250.12:2181
（3）模拟生产者
$KAFKA_HOME/bin/kafka-console-producer.sh --broker-list 192.168.250.10:9092 --topic oggtopic
hello world
（4）打开消费者
$KAFKA_HOME/bin/kafka-console-consumer.sh --zookeeper 192.168.250.10:2181,192.168.250.11:2181,192.168.250.12:2181 --topic oggtopic
（5）删除topic
$KAFKA_HOME/bin/kafka-topics.sh --delete --zookeeper 192.168.250.10:2181,192.168.250.11:2181,192.168.250.12:2181 --topic oggtopic
