kafka安装以及常见问题的解决【如：服务端是ok的，java客户端却始终调不通】

安装步骤：

下载     http://kafka.apache.org/downloads.html

tar -zxvf kafka_2.10-0.8.1.1.tgz

启动服务：  首先启动zookeeper服务    

bin/zookeeper-server-start.sh config/zookeeper.properties &

启动Kafka

bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

建立topic         建立一个"test"的topic，一个分区一个副本     

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看主题  

bin/kafka-topics.sh --list --zookeeper localhost:2181

查看主题详情   

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

删除主题

bin/kafka-run-class.sh kafka.admin.TopicCommand –delete --topic test --zookeeper 10.1.10.77:2181

记得第一次安装时候，java客户端却始终调不通，调了好久，一直不通，都是是按网上步骤一步一步安装的，安装也没有报错，直接在linux上面经过如下命令、

建立生产者 producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

服务端是ok的，可以发送消息

另外开一个secure SSH,一样链接该服务器，建立一个consumer

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

执行以上代码后消费者可以对生产者发送的消息进行消费

可是java 客户端就是调不通，重试3次就抛异常了

注意：若是kafka及zookeeper采用的是集群方式部署的，能够使用如下命令穿件consumer:

[root@centos67-84 kafka_2.11-0.10.0.1]# bin/kafka-console-consumer.sh --zookeeper 10.1.10.83:2181,10.1.10.87:2182,10.1.10.88:2183  --topic test

 能够在任意一台参与集群的系统kafka目录中执行，使用逗号分割集群的zookeeper及端口，zookeeper集群保存在kafka的

[root@centos67-84 config]# pwd
/home/liuwei/kafka_2.11-0.10.0.1/config
[root@centos67-84 config]# ls
connect-console-sink.properties    connect-file-source.properties  log4j.properties        zookeeper.properties
connect-console-source.properties  connect-log4j.properties        producer.properties
connect-distributed.properties     connect-standalone.properties   server.properties
connect-file-sink.properties       consumer.properties             tools-log4j.properties

###查看当前kafka所用的zookeeper
[root@centos67-84 config]# cat server.properties | grep zookeeper
# Zookeeper connection string (see zookeeper docs for details).
zookeeper.connect=10.1.10.83:2181,10.1.10.87:2182,10.1.10.88:2183
# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000

解决方案：

 编辑 这个文件打开下面红色部分加上去，重启kafka就解决啦

[root@localhost kafka_2.11-0.10.1.0]# vi ./config/server.properties  vi ./config/server.properties