Kafka最新环境搭建

1、安装jdk
一、JDK安装
export JAVA_HOME=/usr/jdk1.7.0_60
export JRE_HOME=/usr/jdk1.7.0_60/jre
export PATH=$PATH:/usr/jdk1.7.0_60/bin
export CLASSPATH=./:/usr/jdk1.7.0_60/lib:/usr/jdk1.7.0_60/jre/lib

2、tar -zxvf kafka
3、配置环境变量
export KAFKA_HOME=/soft/kafka
export PATH=.:$JAVA_HOME/bin:$KAFKA_HOME/bin:$PATH
 
测试一下：echo $KAFKA_HOME
------------------------------------------------------------------------------
kafka集群：
single node ---- single broker 单节点  单broker
1、启动zk服务器  zk是协同服务， 在broker  和 consumer之间协同处理。
     $>zookeeper-server-start.sh /soft/kafka/config/zookeeper.properties
     放到后台启动：Ctrl+Z 输入 bg %1 回车
2、启动kafka broker
     kafka-server-start.sh /soft/kafka/config/server.properties
     放到后台启动：Ctrl+Z 输入 bg %2 回车
3、创建主题：topic
> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
> bin/kafka-topics.sh --list --zookeeper localhost:2181
test
4、启动生产者发送消息
> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message