@Test public void close() { reader.close(); verify(consumer).close(); }
@Override public void close() { consumer.close(); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void close() { consumer.close(); } }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void close() { consumer.close(); } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void close() { consumer.close(); } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); @Override ApiaryListenerEvent next(); @Override boolean hasNext(); @Override void remove(); @Override void close(); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void close() { consumer.close(); } private  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, Properties consumerProperties); @VisibleForTesting  KafkaMessageReader(String topicName, MetaStoreEventSerDe eventSerDe, KafkaConsumer<Long, byte[]> consumer); @Override ApiaryListenerEvent next(); @Override boolean hasNext(); @Override void remove(); @Override void close();  }