玩玩kafka1 单机安装
今天主要来一遍kafka单机版的安装，比较简单易上手，关于kafka的介绍我就不贴了，大家可以自行搜索1.首先将tgz包传到centos目录下（这里使用xftp工具）
ok后查看一下tgz包是否已经在目录中
# cd /usr/local/src
# ls -a
2.将tgz包解压缩
# tar -zvxf kafka_2.10-0.8.2.0.tgz
# ln -s kafka_2.10-0.8.2.0 kafka (软链接)
3.启动服务
Kafka用到了Zookeeper，所有首先启动Zookper
# cd kafka
# bin/zookeeper-server-start.shconfig/zookeeper.properties &
查看下是否启动
然后启动Kafka:
# bin/kafka-server-start.sh config/server.properties
这时候看下 kafka是否启动了
上面的启动会占用控制台，启动后只能再复制ssh渠道，你也可以这样启动
# bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &
4.测试
# cd /usr/local/src/kafka
创建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
ok，下面我们创建一个producer 创建完并发送hello
# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
有了producer ，下面来个consumer 可以看到刚才发的消息都过来了
# bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5.结尾
中间遇到 Failed to send messages after 3 tries.的问题
解决办法：
# vim config/server.properties
打开配置文件 将host.name=localhost 的#去掉（红色部分）
# Hostname the broker will bind to. If not set, the server will bind to all interfaces
# host.name=localhost
然后保存后再进行producer 的创建就没问题了。
恩，下面会尝试弄下集群的环境然后写写c#端的demo，不过都是皮毛大家误见怪哈......
页:
[1]