Interface KafkaClientSupplier

@Public
public interface KafkaClientSupplier

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

See Also:

• KafkaStreams(Topology, java.util.Properties, KafkaClientSupplier)

Method Summary

Modifier and Type	Method	Description
default Admin	getAdmin(Map<String,Object> config)	Create an Admin which is used for internal topic management.
Consumer<byte[],byte[]>	getConsumer(Map<String,Object> config)	Create a Consumer which is used to read records of source topics.
Consumer<byte[],byte[]>	getGlobalConsumer(Map<String,Object> config)	Create a Consumer which is used to consume records for GlobalKTable.
Producer<byte[],byte[]>	getProducer(Map<String,Object> config)	Create a Producer which is used to write records to sink topics.
Consumer<byte[],byte[]>	getRestoreConsumer(Map<String,Object> config)	Create a Consumer which is used to read records to restore StateStores.

Method Details

getAdmin

default Admin getAdmin(Map<String,Object> config)

Create an Admin which is used for internal topic management.

Parameters:

config - Supplied by the Properties given to the KafkaStreams

Returns:

an instance of Admin

getProducer

Producer<byte[],byte[]> getProducer(Map<String,Object> config)

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

Parameters:

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

Returns:

an instance of Kafka producer

getConsumer

Consumer<byte[],byte[]> getConsumer(Map<String,Object> config)

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

Parameters:

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

Returns:

an instance of Kafka consumer

getRestoreConsumer

Consumer<byte[],byte[]> getRestoreConsumer(Map<String,Object> config)

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

Parameters:

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

Returns:

an instance of Kafka consumer

getGlobalConsumer

Consumer<byte[],byte[]> getGlobalConsumer(Map<String,Object> config)

Create a Consumer which is used to consume records for GlobalKTable.

Parameters:

config - global consumer config which is supplied by the Properties given to the KafkaStreams

Returns:

an instance of Kafka consumer