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(org.apache.kafka.streams.processor.TopologyBuilder, StreamsConfig, KafkaClientSupplier)

Method Summary

Methods

Modifier and Type	Method and Description
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

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