### Question:
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();  }### Answer:
@Test(expected = UnsupportedOperationException.class) public void remove() { reader.remove(); }