public interface KafkaClientSupplier
KafkaClientSupplier
can be used to provide custom Kafka clients to a KafkaStreams
instance.Modifier and Type | Method and Description |
---|---|
AdminClient |
getAdminClient(Map<String,Object> config)
Create an
AdminClient 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 StateStore s. |
AdminClient getAdminClient(Map<String,Object> config)
AdminClient
which is used for internal topic management.config
- Supplied by the Properties
given to the KafkaStreams
AdminClient
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
Properties
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 Properties
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 Properties
given to the KafkaStreams
Consumer<byte[],byte[]> getGlobalConsumer(Map<String,Object> config)
Consumer
which is used to consume records for GlobalKTable
.config
- global consumer config
which is supplied
by the Properties
given to the KafkaStreams