FlinkSQL消费avro格式的kafka消息，这两个配置 Kafka消费者应该怎么配置啊?

在Flink中消费Kafka的Avro消息，需要配置Flink Kafka消费者的相关参数。首先，需要使用FlinkKafkaConsumer011来定义消费者组ID和主题信息。然后，设置Kafka消费者的Value Format为Avro格式，用于反序列化从Kafka中读取的消息。具体的配置代码如下：

val properties = new Properties()
properties.setProperty("bootstrap.servers", "localhost:9092")
properties.setProperty("group.id", "test")
properties.setProperty("value.format", "avro")
properties.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer")
properties.setProperty("value.deserializer", "io.confluent.kafka.serializers.KafkaAvroDeserializer")
properties.setProperty("schema.registry.url", "http://localhost:8081")

其中，bootstrap.servers是Kafka服务器地址，group.id是消费者组ID，value.format是Value的序列化格式，这里设置为"avro"，表示使用Avro格式。key.deserializer和value.deserializer分别设置了Key和Value的反序列化类。最后，schema.registry.url指定了Avro schema的注册中心地址。