When creating history topic, debezium core module's KafkaDatabaseHistory class make an API call using KafkaAdminClient to get broker default replication factor.

Currently there is a timeout configured hardcoded of 3 sec.

Method

KafkaDatabaseHistory#getKafkaBrokerConfig

Variable

KAFKA_QUERY_TIMEOUT

Why?

When using AWS MSK cluster which had IAM auth enabled along with TLS encryption, 3 sec isn't enough to make the request. Every time it will be timed out.

If we increase that to 30 sec, the connection can proceed.
Note: This is not minimum time that it required, it just a random number.

The aim here is to make that configurable.