避免警告消息“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 打开一个问题,看看你是否能在那里获得一些牵引力。