Kafka 消费者组在 Debian 的使用

在Debian系统上使用Kafka消费者组，你需要遵循以下步骤：

1. 安装Java： Kafka需要Java运行环境，首先确保你的Debian系统已经安装了Java。如果没有，请运行以下命令来安装OpenJDK：

sudo apt update
sudo apt install openjdk-11-jdk

2. 下载并解压Kafka： 从Kafka官网下载最新版本的Kafka，然后将其解压到你的Debian系统上。例如，你可以将Kafka解压到/opt目录：

wget https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz
sudo tar -xzf kafka_2.13-2.8.0.tgz -C /opt

3. 启动Zookeeper和Kafka服务器： 在Debian系统上，你可以使用systemd来管理Kafka服务。首先，创建一个名为/etc/systemd/system/zookeeper.service的文件，包含以下内容：

[Unit]
Description=Apache Zookeeper server
After=network.target

[Service]
Type=simple
User=kafka
ExecStart=/opt/kafka_2.13-2.8.0/bin/zookeeper-server-start.sh /opt/kafka_2.13-2.8.0/config/zookeeper.properties
ExecStop=/opt/kafka_2.13-2.8.0/bin/zookeeper-server-stop.sh

[Install]
WantedBy=multi-user.target

接下来，创建一个名为/etc/systemd/system/kafka.service的文件，包含以下内容：

[Unit]
Description=Apache Kafka server
After=zookeeper.service
Requires=zookeeper.service

[Service]
Type=simple
User=kafka
ExecStart=/opt/kafka_2.13-2.8.0/bin/kafka-server-start.sh /opt/kafka_2.13-2.8.0/config/server.properties
ExecStop=/opt/kafka_2.13-2.8.0/bin/kafka-server-stop.sh

[Install]
WantedBy=multi-user.target

现在，启动Zookeeper和Kafka服务：

sudo systemctl start zookeeper
sudo systemctl start kafka

4. 创建Kafka主题： 使用以下命令创建一个名为my_topic的Kafka主题：

/opt/kafka_2.13-2.8.0/bin/kafka-topics.sh --create --topic my_topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

5. 创建并启动Kafka消费者组： 使用以下命令创建一个名为my_consumer_group的消费者组，并启动消费者：

/opt/kafka_2.13-2.8.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --group my_consumer_group --topic my_topic --from-beginning

现在，你的Kafka消费者组已经在Debian系统上运行，并从my_topic主题消费消息。你可以根据需要调整消费者组的配置和参数。