public interface KafkaClientSupplier
KafkaClientSupplier
can be used to provide custom Kafka clients to a KafkaStreams
instance.Modifier and Type | Method and Description |
---|---|
Consumer<byte[],byte[]> |
getConsumer(Map<String,Object> config)
Create a
Consumer which is used to read records of source topics. |
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 StateStore s. |
Producer<byte[],byte[]> getProducer(Map<String,Object> config)
Producer
which is used to write records to sink topics.config
- producer config
which is supplied by the
StreamsConfig
given to the KafkaStreams
instanceConsumer<byte[],byte[]> getConsumer(Map<String,Object> config)
Consumer
which is used to read records of source topics.config
- consumer config
which is
supplied by the StreamsConfig
given to the KafkaStreams
instanceConsumer<byte[],byte[]> getRestoreConsumer(Map<String,Object> config)
Consumer
which is used to read records to restore StateStore
s.config
- restore consumer config
which is supplied
by the StreamsConfig
given to the KafkaStreams