Hi, Razin. You could pass these Kafka configuration in the format 'properties.*'. For example, 'properties.allow.auto.create.topics' = 'false'. See more in Kafka connector docs[1].
Best, Hang [1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/table/kafka/#properties Razin Bouzar via user <user@flink.apache.org> 于2023年6月22日周四 02:21写道： > Looking for some guidance on overriding Kafka admin client configs. The > partition discovery feature sometimes fails to connect with kafka and we'd > like to implement retries. There is no clear documentation on which > settings need to be changed?admin client configs of note: > > - default.api.timeout.ms -- applies for client ops which do not > specify a timeout param. > - reconnect.backoff.max > > <https://docs.confluent.io/platform/current/installation/configuration/admin-configs.html#reconnect-backoff-max-ms> > - request.timeout.ms > - retries > > <https://docs.confluent.io/platform/current/installation/configuration/admin-configs.html#retries> > - retry.backoff.ms > >
