Skip to content
Snippets Groups Projects

Refactor Kafka topic creation and deletion commands in integrationtest.py to remove absolute path

Open Jekabs Karklins requested to merge fix-absolute-path into master
1 file
+ 3
3
Compare changes
  • Side-by-side
  • Inline
+ 3
3
@@ -42,18 +42,18 @@ def check_stats(test):
def create_kafka_topic(topic_name):
subprocess.Popen(
f"/ess/ecdc/kafka/kafka_2.13-2.8.0/bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic {topic_name}",
f"kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic {topic_name}",
shell=True,
).wait()
subprocess.Popen(
f"/ess/ecdc/kafka/kafka_2.13-2.8.0/bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic {topic_name}",
f"kafka-topics.sh --bootstrap-server localhost:9092 --create --topic {topic_name}",
shell=True,
).wait()
def check_kafka(test):
kafka_process = subprocess.Popen(
f"/ess/ecdc/kafka/kafka_2.13-2.8.0/bin/kafka-verifiable-consumer.sh --bootstrap-server localhost:9092 --topic {test['KafkaTopic']} --group-id testconsumer1",
f"kafka-verifiable-consumer.sh --bootstrap-server localhost:9092 --topic {test['KafkaTopic']} --group-id testconsumer1",
shell=True,
stdout=subprocess.PIPE,
)
Loading