topologylistener.kafkareader Namespace Reference

Functions
def	create_consumer (config)
def	read_message (consumer)

Variables
	logger = logging.getLogger(__name__)

Function Documentation

create_consumer()

def topologylistener.kafkareader.create_consumer

(

config

)

Definition at line 24 of file kafkareader.py.

read_message()

def topologylistener.kafkareader.read_message

(

consumer

)

Definition at line 47 of file kafkareader.py.

Variable Documentation

logger

topologylistener.kafkareader.logger = logging.getLogger(__name__)

Definition at line 21 of file kafkareader.py.