iasDumpKafkaTopic
index
/home/ubuntu/ias/KafkaUtils/src/main/python/iasDumpKafkaTopic.py

Dump the strings published in the kafka topics
by delegating to kafka native commands.
 
No further computation is done on the received strings.

 
Modules
       
IasKafkaUtils.IaskafkaHelper
argparse
os
sys

 
Functions
       
check_kafka(kafkaCommand)
Check if kafka commands exists
:rtype: bool
:param kafkaCommand: kafkaCommand the command to run from KAFKA_HOME
:return: True if kafka is available

 
Data
        DEVNULL = -3
STDOUT = -2