Kafka-connect是否必须使用Schemaregistry？

Kafka-connect 不一定必须使用 Schema registry。使用 Schema registry 主要是为了服务端口的模式注册和版本控制，以及支持数据类型的变化。但是，如果您对数据类型的变化不关心或者不需要使用不同版本的数据模式，则不需要使用 Schema registry。以下是一些不使用 Schema registry 的 Kafka-connect 连接器的示例代码：

1. 使用 AvroEncoder 和 AvroDecoder

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092");

//设置生产者使用的序列化类 props.put("key.serializer", StringSerializer.class.getName()); props.put("value.serializer", AvroEncoder.class.getName()); //设置消费者使用的反序列化类 props.put("key.deserializer", StringDeserializer.class.getName()); props.put("value.deserializer", AvroDecoder.class.getName());

//设置连接器使用的序列化和反序列化类 props.put("key.converter", StringConverter.class.getName()); props.put("value.converter", AvroConverter.class.getName());

2. 使用 JsonConverter

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", StringSerializer.class.getName()); props.put("value.serializer", StringSerializer.class.getName());

//设置连接器使用的序列化和反序列化类 props.put("key.converter", StringConverter.class.getName()); props.put("value.converter", JsonConverter.class.getName());

3. 使用 ByteArrayConverter

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("key.serializer", StringSerializer.class.getName()); props.put("value.serializer", ByteArraySerializer.class.getName());

//设置连接器使用的序列化和反序列化类 props.put("key.converter", StringConverter.class.getName()); props.put("value.converter", ByteArrayConverter.class.getName());