diff options
Diffstat (limited to 'src/main/java')
| -rw-r--r-- | src/main/java/com/att/dmf/mr/backends/Consumer.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/att/dmf/mr/backends/Consumer.java b/src/main/java/com/att/dmf/mr/backends/Consumer.java index 279d48b..2743fc3 100644 --- a/src/main/java/com/att/dmf/mr/backends/Consumer.java +++ b/src/main/java/com/att/dmf/mr/backends/Consumer.java @@ -77,9 +77,9 @@ public interface Consumer * @param atOffset start with the next message at or after atOffset. -1 means next from last request * @return the next message, or null if none are waiting */ -// Message nextMessage ( long atOffset ); - //Message nextMessage (ArrayList cl); + + /** * Close/clean up this consumer * @return @@ -100,7 +100,7 @@ public interface Consumer void setOffset(long offset); - //public org.apache.kafka.clients.consumer.KafkaConsumer getConsumer(); + } |