Linux安装

环境要求：JDK8

  1. 去官网选择合适的版本：http://kafka.apache.org/downloads

wget https://downloads.apache.org/kafka/3.9.1/kafka_2.12-3.9.1.tgz
tar -xzf kafka_2.12-3.9.1.tgz
cd kafka_2.12-3.9.1

  1. 启动服务器：（高版本已经不需要Zookeeper支持）

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

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

  1. 创建topic

bin/kafka-topics.sh --create \
    --bootstrap-server localhost:9092 \
    --replication-factor 1 \
    --partitions 1 \
    --topic mysql-audit-log

  1. 生产者生产消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mysql-audit-log

  1. 消费者消费

bin/kafka-console-consumer.sh --topic mysql-audit-log --group sql-reviewer --bootstrap-server localhost:9092