玩玩kafka1 单机安装

今天主要来一遍kafka单机版的安装,比较简单易上手,关于kafka的介绍我就不贴了,大家可以自行搜索

1.首先将tgz包传到centos目录下(这里使用xftp工具)

     

      ok后查看一下tgz包是否已经在目录中

      [root@hchao src]# cd /usr/local/src

      [root@hchao src]# ls -a

2.将tgz包解压缩

       [root@hchao src]# tar -zvxf kafka_2.10-0.8.2.0.tgz  

       [root@hchao src]# ln -s kafka_2.10-0.8.2.0 kafka   (软链接)

3.启动服务

      Kafka用到了Zookeeper,所有首先启动Zookper

       [root@hchao kafka]# cd kafka

       [root@hchao kafka]# bin/zookeeper-server-start.sh  config/zookeeper.properties &

       查看下是否启动

       

       然后启动Kafka:

       [root@hchao kafka]# bin/kafka-server-start.sh config/server.properties

        这时候看下 kafka是否启动了

       

       上面的启动会占用控制台,启动后只能再复制ssh渠道,你也可以这样启动

       [root@hchao kafka]# bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

4.测试

       [root@hchao ~]# cd /usr/local/src/kafka

       创建topic  (创建一个“test”的topic,一个分区一个副本)

       [root@hchao kafka]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

       

       查看主题

       [root@hchao kafka]# bin/kafka-topics.sh --list --zookeeper localhost:2181

       

       查看主题详情

       [root@hchao kafka]# bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

       

       ok,下面我们创建一个producer 创建完并发送hello

       [root@hchao kafka]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

       

       有了producer ,下面来个consumer 可以看到刚才发的消息都过来了

       [root@hchao kafka]# bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

       

5.结尾

       中间遇到 Failed to send messages after 3 tries.的问题 

       解决办法:

             [root@hchao kafka]# 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,不过都是皮毛大家误见怪哈......

原文地址:https://www.cnblogs.com/Burt/p/6808539.html