Kafka安装与简单应用

1.下载安装

        1.下载地址

                http://archive.apache.org/dist/kafka/0.8.1.1/kafka_2.10-0.8.1.1.tgz

        2.解压安装

tar -xzf kafka_2.10-0.8.1.1.tar.gz

        3.配置server.properties文件

cd /usr/local/kafka/config
vim server.properties
修改属性为：zookeeper.connect=localhost:2181

       4.启动kafka

cd /usr/local/kafka
sh bin/kafka-server-start.sh -daemon config/server.properties

        5.创建topic

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

此时会出现问题：zookeeper is not a recognized option

2.简单应用

3.常见问题

        1. 通过kafka-topics.sh创建topic出错

Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option

        问题原因：查了一些资料说是版本问题，需要换成最新的方式去创建topic 

        2.kafka3.0创建topic方式

        sh bin/kafka-console-producer.sh --broker-list master:9097 --topic test

原文参考：centos安装ZooKeeper和kafka_wushichao0325的博客-CSDN博客_centos7安装zookeeper和kafka

kafka官方文档：Apache Kafka