@Test public void testNoBrokersConfigured() { final KafkaClientProvider provider = new KafkaClientProvider(null); assertEquals("KafkaClientProvider should return absent when null list of seed hosts is passed", Optional.empty(), provider.getDefaultProducer()); }
public Optional<KafkaProducer<String, byte[]>> getDefaultProducer() { return getProducer(new StringSerializer(), new ByteArraySerializer()); }
KafkaClientProvider { public Optional<KafkaProducer<String, byte[]>> getDefaultProducer() { return getProducer(new StringSerializer(), new ByteArraySerializer()); } }
KafkaClientProvider { public Optional<KafkaProducer<String, byte[]>> getDefaultProducer() { return getProducer(new StringSerializer(), new ByteArraySerializer()); } KafkaClientProvider(@Nullable final List<String> brokerList); }
KafkaClientProvider { public Optional<KafkaProducer<String, byte[]>> getDefaultProducer() { return getProducer(new StringSerializer(), new ByteArraySerializer()); } KafkaClientProvider(@Nullable final List<String> brokerList); Optional<KafkaProducer<String, byte[]>> getDefaultProducer(); Optional<KafkaProducer<K, V>> getProducer(
      @NotNull final Serializer<K> keySerializer,
      @NotNull final Serializer<V> valueSerializer); }
KafkaClientProvider { public Optional<KafkaProducer<String, byte[]>> getDefaultProducer() { return getProducer(new StringSerializer(), new ByteArraySerializer()); } KafkaClientProvider(@Nullable final List<String> brokerList); Optional<KafkaProducer<String, byte[]>> getDefaultProducer(); Optional<KafkaProducer<K, V>> getProducer(
      @NotNull final Serializer<K> keySerializer,
      @NotNull final Serializer<V> valueSerializer); static final int MAX_BLOCK_TIMEOUT; }