@Test(expected = SerDeException.class) public void unmarhsallThrowsException() { when(serDe.unmarshal(any(byte[].class))).thenThrow(SerDeException.class); reader.next(); }
@Override public ApiaryListenerEvent next() { readRecordsIfNeeded(); ConsumerRecord<Long, byte[]> next = records.next(); return eventSerDe.unmarshal(next.value()); }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public ApiaryListenerEvent next() { readRecordsIfNeeded(); ConsumerRecord<Long, byte[]> next = records.next(); return eventSerDe.unmarshal(next.value()); } }
KafkaMessageReader implements Iterator<ApiaryListenerEvent>, Closeable { @Override public ApiaryListenerEvent next() { readRecordsIfNeeded(); ConsumerRecord<Long, byte[]> next = records.next(); return eventSerDe.unmarshal(next.value()); } 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 ApiaryListenerEvent next() { readRecordsIfNeeded(); ConsumerRecord<Long, byte[]> next = records.next(); return eventSerDe.unmarshal(next.value()); } 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 ApiaryListenerEvent next() { readRecordsIfNeeded(); ConsumerRecord<Long, byte[]> next = records.next(); return eventSerDe.unmarshal(next.value()); } 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();  }