"The configuration foo.bar was supplied but isn't a known config"

apache-kafka apache-kafka-connect
Mabi picture Mabi · Jan 10, 2018 · Viewed 8.9k times · Source

When I'm starting a connector in distributed mode (connect-runtime v1.0.0), there are several configuration values that are mandatory. I'm speaking of values like:

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
...

Once the connector is started with meaningful values for those properties, it works as expected. But at startup, the log get's flooded with entries like 

WARN  o.a.k.c.admin.AdminClientConfig.logUnused - The configuration 'offset.storage.topic' was supplied but isn't a known config.

for all above mentioned, mandatory configuration values. There are three config classes which are logging there warnings:

org.apache.kafka.clients.consumer.ConsumerConfig
org.apache.kafka.clients.admin.AdminClientConfig
org.apache.kafka.clients.producer.ProducerConfig

Since now I haven't found a reason for this behavior. What's missing here or what is wrong, that causes this warnings? Do I have to worry about this warnings?

Answer

pbamba picture pbamba · Jul 11, 2018

Judging by this thread, it doesn't seem to matter

Related questions

Kafka Connect running out of heap space

After starting Kafka Connect (connect-standalone), my task fails immediately after starting with: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) at org.apache.kafka.common.network.…

Read More
How to connect Kafka with Elasticsearch?

I am new in Kafka, I use kafka to collect netflow through logstash(it is ok), and I want to send the data to elasticsearch from kafka, but there are some problems. My question is how can I connect Kafka …

Read More
How can i get all group list with kafka0.10.x

when i use kafka0.8.x，i can get all group list with zookeeper by path /consumers/group_id, because offsets will commit to zookeeper in 0.8.x. But in version of 0.10.x, offsets commited to kafka broker like a path /brokers/…

Read More