diff options
Diffstat (limited to 'src/main/java')
| -rw-r--r-- | src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java b/src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java index 0b684fe..55e0645 100644 --- a/src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java +++ b/src/main/java/com/att/dmf/mr/backends/ConsumerFactory.java @@ -90,8 +90,7 @@ public interface ConsumerFactory { * @return * @throws UnavailableException */ - //public Consumer getConsumerFor(String topic, String consumerGroupId, - // String clientId, int timeoutMs) throws UnavailableException; + /** * For factories that employ a caching mechanism, this allows callers to |