Невозможно запустить брокеров Kafka, используя скрипт python - PullRequest
1 голос
/ 29 апреля 2020

Я запустил собственную настройку 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

Когда Я запускаю ту же команду на консоли, она работает нормально. Я думаю, что проблема заключается в правильном использовании модуля подпроцесса. Может ли кто-нибудь помочь решить проблему?

Дайте мне знать, если мне нужно предоставить много информации относительно проблемы.

Заранее спасибо.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...