避免警告消息“schema.registry.url”已提供但不是 kafka 配置中的已知配置
Avoid warn messages ‘schema.registry.url’ was supplied but isn’t a known config on kafka configuration
我正在使用 spring-kakfa,我在日志中收到以下警告消息:
WARN org.apache.kafka.clients.admin.AdminClientConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.consumer.ConsumerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.producer.ProducerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.consumer.ConsumerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
在我的 Java 配置中 class 我设置了这个配置:
config.put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, kafkaGenericConfiguration.getSchemaRegistryUrl());
在我的 YAML 配置文件中,我尝试了几种配置类型,但它总是出错……
spring:
kakfa:
properties:
schema.registry.url: "http://localhost:8081"
default:
producer:
configuration:
schema.registry.url: "http://localhost:8081"
producer:
properties:
schema.registry.url: "http://localhost:8081"
请问如何解决这个错误?
提前致谢!
在顶层设置 属性 为所有组件设置它,包括管理员,显然与它无关;所以删除那个。
我同意消费者和生产者日志很烦人,但我明白他们为什么要记录意外的属性,以防出现拼写错误;但通常使用消费者和生产者配置来配置序列化器和反序列化器。
所以,很难知道什么是最好的。
我建议你针对 kafka-clients 打开一个问题,看看你是否能在那里获得一些牵引力。
我正在使用 spring-kakfa,我在日志中收到以下警告消息:
WARN org.apache.kafka.clients.admin.AdminClientConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.consumer.ConsumerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.producer.ProducerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
WARN org.apache.kafka.clients.consumer.ConsumerConfig The configuration 'schema.registry.url' was supplied but isn't a known config.
在我的 Java 配置中 class 我设置了这个配置:
config.put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, kafkaGenericConfiguration.getSchemaRegistryUrl());
在我的 YAML 配置文件中,我尝试了几种配置类型,但它总是出错……
spring:
kakfa:
properties:
schema.registry.url: "http://localhost:8081"
default:
producer:
configuration:
schema.registry.url: "http://localhost:8081"
producer:
properties:
schema.registry.url: "http://localhost:8081"
请问如何解决这个错误? 提前致谢!
在顶层设置 属性 为所有组件设置它,包括管理员,显然与它无关;所以删除那个。
我同意消费者和生产者日志很烦人,但我明白他们为什么要记录意外的属性,以防出现拼写错误;但通常使用消费者和生产者配置来配置序列化器和反序列化器。
所以,很难知道什么是最好的。
我建议你针对 kafka-clients 打开一个问题,看看你是否能在那里获得一些牵引力。