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.KafkaStreams(Topology, java.util.Properties, KafkaClientSupplier)

Method Summary

Modifier and Type	Method and 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.
Consumer<byte[],byte[]>	getGlobalConsumer(java.util.Map<java.lang.String,java.lang.Object> config) Create a Consumer which is used to consume records for GlobalKTable.
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 Properties 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 Properties 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 Properties 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 Properties given to the KafkaStreams

Returns:

an instance of Kafka consumer

getGlobalConsumer

Consumer<byte[],byte[]> getGlobalConsumer(java.util.Map<java.lang.String,java.lang.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