KafkaConsumer.py File Reference

Go to the source code of this file.

Namespaces
	KafkaConsumer

Functions
def	KafkaConsumer.parse_cmdline ()
def	KafkaConsumer.main (args)

Variables
string	KafkaConsumer.KAFKA_BOOTSTRAP_SERVERS = 'hadoop01.staging.pen:6667'
	KafkaConsumer.format
	KafkaConsumer.level
	KafkaConsumer.logger = logging.getLogger(__name__)
def	KafkaConsumer.args = parse_cmdline()