Kafka 安装与配置详细过程

下面是 Kafka 安装与配置的详细攻略：

安装 Kafka

1. 下载 Kafka 压缩包：

wget http://mirrors.ocf.berkeley.edu/apache/kafka/2.8.0/kafka_2.13-2.8.0.tgz

1. 解压缩 Kafka 压缩包：

tar -xzf kafka_2.13-2.8.0.tgz

1. 进入解压后的 Kafka 目录：

cd kafka_2.13-2.8.0

配置 Kafka

1. 创建并编辑 config/server.properties 文件：

cp config/server.properties config/server.properties.bak
vi config/server.properties

1. 修改以下属性的值，以用于本地测试：

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://localhost:9092

启动 Kafka

1. 启动 Zookeeper 服务：

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

1. 启动 Kafka 服务：

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

创建和测试 Topic

1. 创建一个名为 my-topic 的 Topic：

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

1. 启动 Producer 并发送一条消息：

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

1. 启动 Consumer 并消费一条消息：

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

以上就是 Kafka 安装与配置的详细过程，其中包含了创建和测试 Topic 的示例。如果还有其他问题欢迎继续交流。