diff --git a/src/test/groovy/com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcherSpec.groovy b/src/test/groovy/com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcherSpec.groovy index d8aded0..90f7d35 100644 --- a/src/test/groovy/com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcherSpec.groovy +++ b/src/test/groovy/com/github/lookout/verspaetung/zk/AbstractConsumerTreeWatcherSpec.groovy @@ -82,6 +82,13 @@ class AbstractConsumerTreeWatcherSpec extends Specification { then: watcher.consumersMap.size() == 1 watcher.consumersMap[mapKey].size() == 2 + } + + @Ignore + def "removeConsumer() should remove a ConsumerOffset from the map"() { + given: + TopicPartition tp = new TopicPartition('spock', 1) + ConsumerOffset consumer = new ConsumerOffset() } }