分布式消息服务KAFKA版-Logstash对接Kafka生产消费消息:约束与限制

时间:2024-11-28 01:45:13

约束与限制

Logstash从7.5版本开始支持Kafka Integration Plugin插件,Kafka Integration Plugin插件包含Kafka input Plugin和Kafka output Plugin。Kafka input Plugin用于从Kafka实例的Topic中读取数据,Kafka output Plugin把数据写入到Kafka实例的Topic。Logstash、Kafka Integration Plugin与Kafka客户端的版本对应关系如表1所示。请确保Kafka客户端版本大于或等于Kafka实例的版本

表1 版本对应关系

Logstash版本

Kafka Integration Plugin版本

Kafka客户端版本

8.3~8.8

10.12.0

2.8.1

8.0~8.2

10.9.0~10.10.0

2.5.1

7.12~7.17

10.7.4~10.9.0

2.5.1

7.8~7.11

10.2.0~10.7.1

2.4

7.6~7.7

10.0.1

2.3.0

7.5

10.0.0

2.1.0

support.huaweicloud.com/bestpractice-kafka/Kafka_bp_0005.html