@Test public void producerClosed() throws Exception { KafkaWriter2 writer = new KafkaWriter2( producerMock, TOPIC, new DetailedResultSerializer()); writer.close(); verify(producerMock).close(); }
@Override public void close() { producer.close(); }
KafkaWriter2 extends OutputWriterAdapter { @Override public void close() { producer.close(); } }
KafkaWriter2 extends OutputWriterAdapter { @Override public void close() { producer.close(); } KafkaWriter2(@Nonnull Map<String, Object> producerConfig, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); @VisibleForTesting  KafkaWriter2(Producer<String, String> producer, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); }
KafkaWriter2 extends OutputWriterAdapter { @Override public void close() { producer.close(); } KafkaWriter2(@Nonnull Map<String, Object> producerConfig, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); @VisibleForTesting  KafkaWriter2(Producer<String, String> producer, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); @Override void doWrite(Server server, Query query, Iterable<Result> results); @Override void close(); }
KafkaWriter2 extends OutputWriterAdapter { @Override public void close() { producer.close(); } KafkaWriter2(@Nonnull Map<String, Object> producerConfig, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); @VisibleForTesting  KafkaWriter2(Producer<String, String> producer, @Nonnull String topic, @Nonnull ResultSerializer resultSerializer); @Override void doWrite(Server server, Query query, Iterable<Result> results); @Override void close();  }