formatting tweaks

Author: tim-quix

python/destinations/kafka/sink.py

@@ -136,13 +136,15 @@ def setup(self):
             name=self._topic_name,
             value_serializer=self._value_serializer,
             key_serializer=self._key_serializer,
-            create_config=self._origin_topic.broker_config if self._origin_topic else None
+            create_config=self._origin_topic.broker_config
+            if self._origin_topic
+            else None,
         )
 
         if self._auto_create_sink_topic:
             admin = TopicAdmin(
                 broker_address=self._broker_address,
-                extra_config=self._producer_extra_config
+                extra_config=self._producer_extra_config,
             )
             admin.create_topics(topics=[self._topic])
 
@@ -214,4 +216,4 @@ def flush(self) -> None:
             )
             raise SinkBackpressureError(retry_after=10.0)
 
-        logger.debug(f'Successfully flushed KafkaSink for topic "{self._topic_name}"')
+        logger.debug(f'Successfully flushed KafkaSink for topic "{self._topic_name}"')