#NEWLINE# def __init__( self , producer , topic_prefix , aKafka , logger , appids , use_base64 ) : #NEWLINE# #INDENT# self . producer = producer #NEWLINE# self . topic_prefix = aKafka #NEWLINE# self . topic_list = [ ] #NEWLINE# self . kafka = aKafka #NEWLINE# self . appid_topics = appids #NEWLINE# self . logger = logger #NEWLINE# self . logger . debug ( 'Setup kafka pipeline' ) #NEWLINE# self . use_base64 = use_base64