Я запустил собственную настройку zookeeper и теперь пытаюсь запустить брокеров Kafka, используя скрипт python, и наблюдаю, что он не подключается к zookeeper и все операции завершаются неудачно.
def start(self):
cmd_split = shlex.split(self.cmd)
self.process = subprocess.Popen(cmd_split, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
print("Running :", self.cmd)
print("Started broker %d on PID : %d" % (self.broker_id, self.process.pid))
Running : /u/donthu/subs_logs/kafka_2.12-2.4.1/bin/kafka-server-start.sh /u/donthu/subs_logs/kafka_2.12-2.4.1/config/server.properties --override broker.id=0 --override listeners=PLAINTEXT://:9080 --override log.dirs=/tmp/kafka0-logs
Когда Я запускаю ту же команду на консоли, она работает нормально. Я думаю, что проблема заключается в правильном использовании модуля подпроцесса. Может ли кто-нибудь помочь решить проблему?
Дайте мне знать, если мне нужно предоставить много информации относительно проблемы.
Заранее спасибо.