当我以分布式模式(connect-runtime 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
从现在起我还没有找到这种行为的原因.什么在这里丢失或出了什么问题导致这个警告？我不得不担心这个警告吗？
我正在使用Kafka-Connect API实现自定义源连接器，可用于轮询REST-API并将JSON响应接收到Kafka主题中。现在，我想知道如何实现SourceTask的轮询间隔，JDBC连接器如何提供轮询间隔。我必须在某个地方将线程设置为睡眠状态，但是我必须在哪里执行此操作？