安装Kafka Broker

1、安装jdk

2、安装Zookeeper

3、安装kafka

只需要下载，解压，适当修改配置文件，然后启动即可（可以配置环境变量），启动命令：

kafka-server-start.sh -daemon /usr/local/kafka_2.12-3.0.0/config/server.properties

4、验证是否成功安装

首先创建一个测试主题（如果出现UnrecognizedOptionException: zookeeper is not a recognized option，可能是版本的问题，不同版本使用方式不一样，可以通过--help查看具体options）：

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

查看刚刚创建的topic的详细信息：

# kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic test
Topic: test     TopicId: 69XAtsB4Q1m0BtPbYbsddg PartitionCount: 1       ReplicationFactor: 1    Configs: segment.bytes=1073741824
        Topic: test     Partition: 0    Leader: 0       Replicas: 0     Isr: 0

往测试主题发布一些消息：

kafka-console-producer.sh --broker-list localhost:9092 --topic test
>Test Message 1
>Test Message 2

从测试主题读取消息：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
Test Message 1
Test Message 2

Broker配置