public class DefaultKafkaClientSupplier extends java.lang.Object implements KafkaClientSupplier
Constructor and Description |
---|
DefaultKafkaClientSupplier() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.admin.AdminClient |
getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
Create an
AdminClient which is used for internal topic management. |
org.apache.kafka.clients.consumer.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. |
org.apache.kafka.clients.consumer.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 . |
org.apache.kafka.clients.producer.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. |
org.apache.kafka.clients.consumer.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 StateStore s. |
public org.apache.kafka.clients.admin.AdminClient getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
KafkaClientSupplier
AdminClient
which is used for internal topic management.getAdminClient
in interface KafkaClientSupplier
config
- Supplied by the Properties
given to the KafkaStreams
AdminClient
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> getProducer(java.util.Map<java.lang.String,java.lang.Object> config)
KafkaClientSupplier
Producer
which is used to write records to sink topics.getProducer
in interface KafkaClientSupplier
config
- producer config
which is supplied by the
Properties
given to the KafkaStreams
instancepublic org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
KafkaClientSupplier
Consumer
which is used to read records of source topics.getConsumer
in interface KafkaClientSupplier
config
- consumer config
which is
supplied by the Properties
given to the KafkaStreams
instancepublic org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getRestoreConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
KafkaClientSupplier
Consumer
which is used to read records to restore StateStore
s.getRestoreConsumer
in interface KafkaClientSupplier
config
- restore consumer config
which is supplied
by the Properties
given to the KafkaStreams
public org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getGlobalConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
KafkaClientSupplier
Consumer
which is used to consume records for GlobalKTable
.getGlobalConsumer
in interface KafkaClientSupplier
config
- global consumer config
which is supplied
by the Properties
given to the KafkaStreams