org.apache.kafka.streams

Interface KafkaClientSupplier

public interface KafkaClientSupplier

Method Summary

Methods

Modifier and Type	Method and Description
Consumer<byte[],byte[]>	getConsumer(Map<String,Object> config) Creates an instance of Consumer which is used to consume records of source topics.
Producer<byte[],byte[]>	getProducer(Map<String,Object> config) Creates an instance of Producer which is used to produce records.
Consumer<byte[],byte[]>	getRestoreConsumer(Map<String,Object> config) Creates an instance of Consumer which is used to consume records of internal topics.

Method Detail

getProducer

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

Creates an instance of Producer which is used to produce records.

Parameters:

config - producer config which supplied by StreamsConfig given to KafkaStreams

Returns:

an instance of kafka Producer

getConsumer

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

Creates an instance of Consumer which is used to consume records of source topics.

Parameters:

config - consumer config which supplied by StreamsConfig given to KafkaStreams

Returns:

an instance of kafka Consumer

getRestoreConsumer

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

Creates an instance of Consumer which is used to consume records of internal topics.

Parameters:

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

Returns:

an instance of kafka Consumer