#138 - kafka.read - reformat - missed file

datayoga-io · Feb 18, 2024 · 9a74193 · 9a74193
1 parent 3533eb0
commit 9a74193
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/integration-tests/common/kafka_utils.py b/integration-tests/common/kafka_utils.py
@@ -1,8 +1,11 @@
 from kafka import KafkaProducer
 from testcontainers.kafka import KafkaContainer
+
+
 def get_kafka_container() -> KafkaContainer:
     return (KafkaContainer(image="confluentinc/cp-kafka:latest")
             .with_bind_ports(KafkaContainer.KAFKA_PORT, KafkaContainer.KAFKA_PORT))
 
+
 def get_kafka_producer(bootstrap_servers: str) -> KafkaProducer:
     return KafkaProducer(bootstrap_servers=bootstrap_servers)