为什么迁移
- 内存占用更低
- 配置更简洁
- 性能更好
配置对比
Logstash
input {
kafka {
bootstrap_servers => "kafka:9092"
topics => ["logs"]
}
}Vector
[sources.kafka_logs]
type = "kafka"
bootstrap_servers = "kafka:9092"
topics = ["logs"]迁移步骤
1. 部署 Vector(shadow 模式)
2. 对比输出数据
3. 灰度切换流量
4. 下线 Logstash