@Test public void testReturnsProvider() { final ImmutableList<String> hosts = ImmutableList.of("localhost:2181"); final KafkaClientProvider provider = new KafkaClientProvider(hosts); assertTrue("Expected KafkaProvider to return non-absent KafkaProducer " + "when passed a list of seed hosts", provider.getDefaultProducer().isPresent()); }
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; }