Kafka Connect 数据格式转换器
Kafka Connect 支持以下数据格式转换器:
1. Avro Converter
- 用途:将数据序列化为 Avro 格式。
- 特点:支持模式(Schema),适合需要严格数据结构的场景。
- 配置示例:
key.converter=io.confluent.connect.avro.AvroConverter
key.converter.schema.registry.url=http://schema-registry:8081
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://schema-registry:8081
2. Protobuf Converter
- 用途:将数据序列化为 Protobuf 格式。
- 特点:适合高性能、低延迟的场景,支持模式(Schema)。
- 配置示例:
key