linux kafka 安装与测试

事先把java装好，环境变量设置好（省略）

centos 下安装kafka过程：

去到apache官网上

下载图中这种Scala版本的，解压完，将文件拷到/usr/local/  下，搞一个软链接/usr/local/kafka 指向它 ，需要sudo 权限。

单机测试，使用kafka里自带的zookeeper，进到kafka目录，执行：

sudo ./bin/zookeeper-server-start.sh config/zookeeper.properties （可加-daemon后台启动）

启动zookeeper

再执行：

sudo ./bin/kafka-server-start.sh config/server.properties （可加-daemon后台启动）

启动kafka服务，若要修改配置，可打开配置文件进行修改。

这里有个地方，就是使用localhost需要/etc/hosts 文件下有相应的配置语句，如：

 

 

kafka启动完成后使用kafka自带的生产者和消费者测试程序进行测试：

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

创建一个名为testtopic的topic

打开消费者从头进行数据读取：

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testtopic --from-beginning

 

再开一个终端从testtopic写入消息

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

随便输入，消费者那边就能显示到消费的消息：