Unable to push the tcollector metrics to kafka using kafka_dumper.py script

[MohamedHz]

Hi Robin,

I am planning to monitor the infrastructure using kafka + opentsdb using the agent tcollector.

So, I just import the python script(kafka_dumper.py) into the tcollector path (/usr/local/tcollector/collectors/0) but it was not working.

Tcollector log

2017-07-26 14:38:47,210 tcollector[11908] INFO: kafka_dumper.py (interval=0) needs to be spawned
2017-07-26 14:38:47,214 tcollector[11908] ERROR: Failed to spawn collector /usr/local/tcollector/collectors/300/kafka_dumper.py: [Errno 8] Exec format error

Then I just tried to run the script by using in command line and I am not sure which argument should pass in command line, Could you help me please ?

[root@server 300]# python kafka_dumper.py --argument ?--------

Error

[root@server 300]# python kafka_dumper.py /brokers/ids/0
^CTraceback (most recent call last):
File "kafka_dumper.py", line 108, in
process_stdin(sys.argv[1])
File "kafka_dumper.py", line 94, in process_stdin
for line in sys.stdin:

Configuration

I have only one brokers in kafka node and kafka_dumper.py configuration file and broker id is 0. Please correct if my configurations are wrong.

[root@server 300]# cat kafka_dumper.py | grep zk_hosts
zk_hosts = "192.168.231.7:2181"
zk_hosts, znode_path = kafka_znode.split("/", 1)
zk_hosts = kafka_znode
hosts=zk_hosts,

Thank you in advance.