kafkareader.py File Reference

Go to the source code of this file.

Namespaces
	topologylistener.kafkareader

Functions
def	topologylistener.kafkareader.create_consumer (config)
def	topologylistener.kafkareader.read_message (consumer)

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