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

Purge all the logs from a kafka topic.
 
IAS does not normally need to purge logs from topic but for testing
it can be better to start from an empty topic instead of getting messages
left over by a previous test
 
This is accomplished by deleting the topic with a native kafka command.
 
Prerequisite: delete.topic.enable=true
              must be set in the kafka server properties file

 
Modules
       
IasKafkaUtils.IaskafkaHelper
argparse
os
sys