diff --git a/metadata-ingestion/src/datahub/configuration/kafka.py b/metadata-ingestion/src/datahub/configuration/kafka.py index fa9b3a3c28..38430bdd34 100644 --- a/metadata-ingestion/src/datahub/configuration/kafka.py +++ b/metadata-ingestion/src/datahub/configuration/kafka.py @@ -16,7 +16,10 @@ class _KafkaConnectionConfig(ConfigModel): description="Extra schema registry config serialized as JSON. These options will be passed into Kafka's SchemaRegistryClient. https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html?#schemaregistryclient", ) - client_timeout_seconds: int = Field(default=60, description="The request timeout used when interacting with the Kafka APIs.") + client_timeout_seconds: int = Field( + default=60, + description="The request timeout used when interacting with the Kafka APIs.", + ) @validator("bootstrap") def bootstrap_host_colon_port_comma(cls, val: str) -> str: