Package org.apache.kafka.streams

Interface KafkaClientSupplier

public interface KafkaClientSupplier

KafkaClientSupplier can be used to provide custom Kafka clients to a KafkaStreams instance.

See Also:

KafkaStreams(org.apache.kafka.streams.Topology, StreamsConfig, KafkaClientSupplier)

Method Summary

Modifier and Type	Method	Description
AdminClient	getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)	Create an AdminClient which is used for internal topic management.
Consumer<byte[],byte[]>	getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)	Create a Consumer which is used to read records of source topics.
Producer<byte[],byte[]>	getProducer(java.util.Map<java.lang.String,java.lang.Object> config)	Create a Producer which is used to write records to sink topics.
Consumer<byte[],byte[]>	getRestoreConsumer(java.util.Map<java.lang.String,java.lang.Object> config)	Create a Consumer which is used to read records to restore StateStores.

Method Detail

getAdminClient

AdminClient getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)

Create an AdminClient which is used for internal topic management.

Parameters:

config - Supplied by the StreamsConfig given to the KafkaStreams

Returns:

an instance of AdminClient

getProducer

Producer<byte[],byte[]> getProducer(java.util.Map<java.lang.String,java.lang.Object> config)

Create a Producer which is used to write records to sink topics.

Parameters:

config - producer config which is supplied by the StreamsConfig given to the KafkaStreams instance

Returns:

an instance of Kafka producer

getConsumer

Consumer<byte[],byte[]> getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)

Create a Consumer which is used to read records of source topics.

Parameters:

config - consumer config which is supplied by the StreamsConfig given to the KafkaStreams instance

Returns:

an instance of Kafka consumer

getRestoreConsumer

Consumer<byte[],byte[]> getRestoreConsumer(java.util.Map<java.lang.String,java.lang.Object> config)

Create a Consumer which is used to read records to restore StateStores.

Parameters:

config - restore consumer config which is supplied by the StreamsConfig given to the KafkaStreams

Returns:

an instance of Kafka consumer