快速搭建kafka

1 安装准备

• 系统版本：CentOS 6.x-7.x
• zookeeper版本：3.4.6，zk安装请参考快速搭建ZooKeeper
• kafka版本：0.11.0.3
• 下载链接：https://kafka.apache.org/downloads

2 单机安装过程

选择安装目录：例如安装在/usr/local/或者/opt/下都可以。

$ tar -zxvf kafka_2.12-0.11.0.3.tgz -C /opt/
$ cd /opt

建立一个软链接：

$ ln -s kafka_2.12-0.11.0.3 kafka

配置：
编辑kafka安装目录下config/server.properties文件：

$ vim config/server.properties

# 添加修改的内容
delete.topic.enable=true
auto.create.topics.enable=false

zookeeper.connect=111.11.1.243:2181

配置完毕。注上面111.11.1.243:2181请换成你自己的zookeeper地址。

3 启动测试

注zookeeper必须先启动，这里不再作启动介绍，需要见快速搭建ZooKeeper
启动kafka server:

$ nohup bin/kafka-server-start.sh config/server.properties &

启动输出日志打印在nohup.out文件当中，查看kafka是否启动：

$ jps
30089 Kafka

我们看到kafka-server已经启动了，接下来创建一个topic:

$ bin/kafka-topics.sh --create --zookeeper 111.11.1.243:2181 --replication-factor 1 --partitions 1 --topic test
Created topic "test"

注test是我取的topic名，根据实际需要自己取。
查看topic:

$ bin/kafka-topics.sh --list --zookeeper 111.11.1.243:2181
test

我们可以看到名为test的topic已经创建成功了，接下来创建一个生产者：

$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message

创建一个消费者：

$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
This is a message
This is another message

停止

$ jps
1794 DataNode
3522 Jps
18506 Kafka
1899 NodeManager
$ kill -9 18506

更多资料请参考官网。