public boolean addMessageListener ( String consumerGroupId , boolean consumeFromBeginning , String topic , IKafkaMessageListener messageListener ) { KafkaMsgConsumer kafkaConsumer = getKafkaConsumer ( consumerGroupId , consumeFromBeginning ) ; return kafkaConsumer . addMessageListener ( topic , messageListener ) ; }
Adds a message listener for a topic .