High-level consumer abstraction #3

src/main/java/com/github/nginate/kafka/KafkaMessage.java

@@ -0,0 +1,11 @@
+package com.github.nginate.kafka;
+
+public interface KafkaMessage<T> {
+    long getTimestamp();
+
+    void setTimestamp(long timestamp);
+
+    T getPayload();
+
+    void setPayload(T payload);
+}

src/main/java/com/github/nginate/kafka/consumer/KafkaConsumer.java

@@ -0,0 +1,9 @@
+package com.github.nginate.kafka.consumer;
+
+public interface KafkaConsumer<T> {
+    void poll();
+
+    void addMessageHandler(MessageHandler<T> messageHandler);
+
+    void removeMessageHandler(MessageHandler<T> messageHandler);
+}

src/main/java/com/github/nginate/kafka/consumer/MessageHandler.java

@@ -0,0 +1,8 @@
+package com.github.nginate.kafka.consumer;
+
+import com.github.nginate.kafka.KafkaMessage;
+
+@FunctionalInterface
+public interface MessageHandler<T> {
+    void onMessage(KafkaMessage<T> message);
+}