# 下载kafka
[root@localhost kafka]# tar -xzf kafka_2.11-2.0.0.tgz
[root@localhost kafka]# cd kafka_2.
[root@localhost kafka_2.0]# pwd
/usr/local/programs/kafka/kafka_2.ls
bin  config  libs  LICENSE  logs  NOTICE  site-docs
[root@localhost kafka_2.]#

# 启动zookeeper
[root@localhost kafka_2.0]# bin/zookeeper-server-start.sh config/zookeeper.properties &

# 启动一个Kafka Server
[root@localhost kafka_2.0]# bin/kafka-server-start.sh config/server.properties

# 创建包含多个broker（Kafka Server）的集群
[root@localhost kafka_2.cp config/server.properties config/server-1.properties
[root@localhost kafka_2.20]# vim config/server-.properties
    broker.id=
    listeners=PLAINTEXT://:9093
    log.dirs=/tmp/kafka-logs-
    zookeeper.connect=localhost:2181:9094
    log.dirs=/tmp/kafka-logs-sh config/server-1.properties &2.properties &0]# netstat -tnlp | grep 909
tcp6       0      0 :::9092                 :::*                    LISTEN      18663/java          
tcp6       9093                 :::*                    LISTEN      18998/9094                 :::*                    LISTEN      19332/java

# 创建一个主题
[root@localhost kafka_2.0]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

# 查看主题
[root@localhost kafka_2.sh --describe --zookeeper localhost:2181 --topic test
Topic:test      PartitionCount:1        ReplicationFactor:3     Configs:
        Topic: test     Partition: 0    Leader: 2       Replicas: 2,0,1)">1 Isr: 1,1)">

# 发送消息
[root@localhost kafka_2.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
>Hello World
>Hello Java
>^C

# 接收消息
[root@localhost kafka_2.0]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test
Hello World
Hello Java

[root@localhost conf]# vim $KE_HOME/conf/system-config.properties

######################################
# multi zookeeper&kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=localhost:2181
#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181

######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25

######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048

######################################
# kafka offset storage
######################################
kafka.eagle.offset.storage=kafka

######################################
# enable kafka metrics
######################################
kafka.eagle.metrics.charts=false

######################################
# alarm email configure
######################################
kafka.eagle.mail.enable=true
kafka.eagle.mail.sa=alert_sa
kafka.eagle.mail.username=alert_sa@163.com
kafka.eagle.mail.password=mqslimczkdqabbbg
kafka.eagle.mail.server.host=smtp.163.com
kafka.eagle.mail.server.port=25

######################################
# delete kafka topic token
######################################
kafka.eagle.topic.token=keadmin

######################################
# kafka sasl authenticate
######################################
kafka.eagle.sasl.enable=false
kafka.eagle.sasl.protocol=SASL_PLAINTEXT
kafka.eagle.sasl.mechanism=PLAIN

######################################
# kafka jdbc driver address
######################################
kafka.eagle.driver=com.MysqL.jdbc.Driver
kafka.eagle.url=jdbc:MysqL://10.123.52.189:3306/oh_coupon
kafka.eagle.username=devdb
kafka.eagle.password=d^V$0Fu!/6-<

[root@localhost kafka-eagle-web-1.2.3]# cd bin/
[root@localhost bin]# 
ke.bat  ke.pid  ke.shchmod +x ke.
[root@localhost bin]# ./ke.sh start