kafka单机简单安装与测试

kafka单机简单安装与测试

1,下载并解压kakfa 地址 http://kafka.apache.org/downloads.html 解压 kafka_2.10-0.10.1.1.tgz 2,kafka集群需要zookeeper, 下载zookeeper并解 http://apache.fayea.com/zookeeper/ 3,编辑kafka,配置文件 进入解压后的kafka目录，修改server.propertis文件 设置listeners=PLAINTEXT://172.16.165.143:9092（当前机器ip） 其它参数默认值 4, 启动kafka, 先启动zookeeper,进入zookeeper的bin目录，执行./zkService.sh start 启动kafka 进入kafka bin目录，执行./kafka-server-start.sh ../config/server.properties 。 5,查看 zookeeper和kafka是否启动成功 创建一个topic : ./kafka-topics.sh –zookeeper localhost:2181 –create –topic test4 –partitions 1 –replication-factor 1 表示 test4 1分区，1个副本， 查看topic list : ./kafka-topics.sh –zookeeper localhost:2181 –list ;可查看到上面 刚创建的 test4 启动producer 打开新的终端 : bin/kafka-console-producer.sh –broker-list 172.16.165.143:9092 –sync –topic test4 启动consumer 打开新的终端： bin/kafka-console-consumer.sh –zookeeper localhost:2181 –topic test4 –from-beginning 测试： producer终端输入 hello kafka，查看consumer终端是否接口到消息

6,原码地址