Skip to content

Commit 355ac71

Browse files
committed
Remove static variables from kafka.
1 parent ad3aef7 commit 355ac71

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

kafka/testcontainers/kafka/__init__.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,9 @@ class KafkaContainer(DockerContainer):
2323
>>> with KafkaContainer() as kafka:
2424
... connection = kafka.get_bootstrap_server()
2525
"""
26-
KAFKA_PORT = 9093
2726
TC_START_SCRIPT = '/tc-start.sh'
2827

29-
def __init__(self, image: str = "confluentinc/cp-kafka:5.4.3", port_to_expose: int = KAFKA_PORT,
28+
def __init__(self, image: str = "confluentinc/cp-kafka:5.4.3", port_to_expose: int = 9093,
3029
**kwargs) -> None:
3130
super(KafkaContainer, self).__init__(image, **kwargs)
3231
self.port_to_expose = port_to_expose

0 commit comments

Comments
 (0)