kafka-streams-KafkaClientSupplier.adoc

KafkaClientSupplier

KafkaClientSupplier is the contract for objects that can provide (supply) Kafka clients, i.e. AdminClient, Producer, Consumer and restore Consumer.

Note	DefaultKafkaClientSupplier is the default KafkaClientSupplier.

KafkaClientSupplier Contract

package org.apache.kafka.streams;

interface KafkaClientSupplier {
  AdminClient getAdminClient(final Map<String, Object> config);
  Producer<byte[], byte[]> getProducer(final Map<String, Object> config);
  Consumer<byte[], byte[]> getConsumer(final Map<String, Object> config);
  Consumer<byte[], byte[]> getRestoreConsumer(final Map<String, Object> config);
}

Table 1. KafkaClientSupplier Contract

Method	Description
getAdminClient	Used exclusively when KafkaStreams is created (and creates the AdminClient)
getProducer	Used when…​
getConsumer	Used when…​
getRestoreConsumer	Used when…​