当我在分布式模式(连接运行时 v1.0.0(下启动连接器时,有几个配置值是必需的。我说的是这样的价值观:
offset.storage.topic
offset.storage.partitions
key.converter
config.storage.topic
config.storage.replication.factor
rest.port
status.storage.topic
key.converter.schemas.enable
value.converter.schemas.enable
internal.value.converter
internal.key.converter
internal.key.converter.schemas.enable
internal.value.converter.schemas.enable
status.storage.partitions
status.storage.topic
value.converter
offset.flush.interval.ms
offset.storage.replication.factor
...
使用这些属性的有意义的值启动连接器后,它将按预期工作。但是在启动时,日志中充斥着诸如
WARN o.a.k.c.admin.AdminClientConfig.logUnused - The configuration 'offset.storage.topic' was supplied but isn't a known config.
对于上述所有必需配置值。有三个配置类正在记录这些警告:
org.apache.kafka.clients.consumer.ConsumerConfig
org.apache.kafka.clients.admin.AdminClientConfig
org.apache.kafka.clients.producer.ProducerConfig
从现在开始,我就没有找到这种行为的原因。这里缺少什么或有什么问题,导致此警告?我必须担心此警告吗?
有一张票,截至 11 月 19 日仍然开放:https://issues.apache.org/jira/browse/KAFKA-7509
运行 Connect 时,日志包含大量有关"提供了配置'{}',但不是已知配置"的警告。当 Connect 创建生产者、使用者和管理客户端时,会发生这种情况,因为 AbstractConfig 在构造时记录未使用的配置属性。由于生产者,消费者和AdminClient都在构造函数中创建自己的AbstractConfig实例,因此我们甚至不能调用其ignore(String key(方法,因此情况变得复杂。
KafkaStreams也存在类似的问题:https://issues.apache.org/jira/browse/KAFKA-6793
从这个线程来看,这似乎并不重要