Linux安装 kafka

linux 安装 kafka

之前参照一些博客，安装kafka都遇到了一些问题，最后还是跟着官网的步骤才解决问题，官方的才稳啊！目前仅仅是个单机版，学习用，集群还需再研究。
下载最新版kafka，当前最新版是kafka_2.13-2.6.0。
按照官方给的提示去做，就可以了。此版本已自带zookeeper，无需单独安装zookeeper。

1、下载 最新的Kafka版本并解压缩：
$ tar -xzf kafka_2.13-2.6.0.tgz
$ cd kafka_2.13-2.6.0

2、运行以下命令以正确的顺序启动所有服务：
启动内置zookeeper：

$ bin/zookeeper-server-start.sh config/zookeeper.properties

打开另一个终端会话并启动kafka：

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

成功启动所有服务后，您将运行并可以使用基本的Kafka环境。

3、编写事件
编写第一个事件之前，必须创建一个topic主题。
打开另一个终端会话并运行

$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Kafka的所有命令行工具都有其他选项：kafka-topics.sh不带任何参数的命令即可显示使用情况信息。例如，它还可以向您显示 详细信息，例如 新主题的分区数：

$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
Topic:quickstart-events  PartitionCount:1    ReplicationFactor:1 Configs:
    Topic: quickstart-events Partition: 0    Leader: 0   Replicas: 0 Isr: 0

• 生产者创建主题

$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event

• 消费者订阅主题

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

按ctrl+c即可结束。
此时生产者发布的消息，消费者就能看到。

注意：所有例子来源于官网http://kafka.apache.org/quickstart#quickstart_download，可至官网查看详情。

如果之前安装过kafka，如需重新安装，必须清除在config文件夹下的kafka配置文件server.properties中 log.dirs=*** 指定的路径下的所有文件（rm -rf ./*），然后重启kafka，以免kafka启动报错。