在Debian系统上稳定运行Kafka需要经过一系列步骤,包括安装、配置、启动以及监控等。以下是详细的步骤和建议:
wget -qO - https://packages.confluent.io/deb/6.2/archive.key | sudo apt-key add -
echo "deb [archamd64] https://packages.confluent.io/deb/6.2 stable main" | sudo tee /etc/apt/sources.list.d/confluent.list
sudo apt-get update
sudo apt-get install kafka_2.13-2.8.0
sudo nano /etc/kafka/server.properties
default.replication.factor=3
min.insync.replicas=2
sudo systemctl restart kafka
sudo systemctl status kafka
kafka-topics --describe --topic my-topic --bootstrap-server localhost:9092
sudo apt update
sudo apt install openjdk-11-jdk
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
bin/kafka-topics.sh --create --topic my-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
创建consumer.properties
文件并添加以下内容:
bootstrap.servers=localhost:9092
group.id=my-consumer-group
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
auto.offset.reset=earliest
enable.auto.commit=true
auto.commit.interval.ms=1000
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --group my-consumer-group --properties consumer.properties
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-consumer-group
在Kafka Producer的配置文件中启用压缩,例如启用Snappy压缩:
compression.type=snappy
在Kafka Broker的配置文件中启用压缩:
compression.type=snappy
sudo apt update
sudo apt upgrade
sudo apt full-upgrade
sudo apt autoremove
sudo systemctl stop kafka
sudo systemctl start kafka
kafka-topics.sh --list
请注意,具体的配置和步骤可能会因Kafka和Debian版本的不同而有所差异,建议在进行任何升级或配置更改之前,详细阅读Kafka和Debian的官方文档,并在测试环境中进行充分的测试。