@Test(expected = UnsupportedOperationException.class) public void remove() { reader.remove(); }
@Override public void remove() { throw new UnsupportedOperationException("Cannot remove message from Kafka topic"); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void remove() { throw new UnsupportedOperationException("Cannot remove message from Kafka topic"); } }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public void remove() { throw new UnsupportedOperationException("Cannot remove message from Kafka topic"); } 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 remove() { throw new UnsupportedOperationException("Cannot remove message from Kafka topic"); } 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 remove() { throw new UnsupportedOperationException("Cannot remove message from Kafka topic"); } 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();  }