package com.anand.simple.kafka.messagebus.consumer;

public interface Consumer<T> {

	T receive();
}

@@ -49,40 +49,445 @@
 er;%0A
-%0Apublic interface Consumer%3CT%3E %7B%0A
+/**%0A * Consumer that can consume message of Type T from Apache Kafka, Message Type T will be decided by decoder %0A * for consumer.%0A * %0A * @author Aishwarya Anand%0A * @param %3CT%3E%0A *            - Type T is message type that Consumer will receive%0A */%0Apublic interface Consumer%3CT%3E %7B%0A%0A%09/**%0A%09 * Consumes message of a specific Type%0A%09 * %0A%09 * @return  T%0A%09 *            - Type T is message type that Consumer will consume from%0A%09 * %09%09Apache Kafka%0A%09 */
 %0A%09T 

Update Consumer.java