KafkaConsumer Namespace Reference

Functions
def	parse_cmdline ()
def	main (args)

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

Function Documentation

main()

def KafkaConsumer.main

(

args

)

Definition at line 32 of file KafkaConsumer.py.

parse_cmdline()

def KafkaConsumer.parse_cmdline

(

)

Definition at line 25 of file KafkaConsumer.py.

Variable Documentation

args

def KafkaConsumer.args = parse_cmdline()

Definition at line 51 of file KafkaConsumer.py.

format

KafkaConsumer.format

Definition at line 47 of file KafkaConsumer.py.

KAFKA_BOOTSTRAP_SERVERS

string KafkaConsumer.KAFKA_BOOTSTRAP_SERVERS = 'hadoop01.staging.pen:6667'

Definition at line 22 of file KafkaConsumer.py.

level

KafkaConsumer.level

Definition at line 48 of file KafkaConsumer.py.

logger

KafkaConsumer.logger = logging.getLogger(__name__)

Definition at line 50 of file KafkaConsumer.py.