def getconsumer(self): #read message from kafka self.consumer = KafkaConsumer(self.topic) print( self.topic, 'consumer created') return self.consumer
