Ravi created KAFKA-9937:
---------------------------
Summary: Unable to start Kafka broker using python script
Key: KAFKA-9937
URL: https://issues.apache.org/jira/browse/KAFKA-9937
Project: Kafka
Issue Type: Bug
Components: KafkaConnect, zkclient
Reporter: Ravi
I have started my own zookeeper setup and now i am trying to start Kafka
brokers using python script and i am observing that its not connecting to
zookeeper and all operations are failing.
{code:java}
// code placeholder
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
{code}
When i run the same command on console , its working fine.I think the problem
lies in using subprocess module properly. Any body know what may be the issue
for not connecting ?
Thanks in advance.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)