Class DefaultKafkaClientSupplier
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier
-
- All Implemented Interfaces:
KafkaClientSupplier
public class DefaultKafkaClientSupplier extends java.lang.Object implements KafkaClientSupplier
-
-
Constructor Summary
Constructors Constructor Description DefaultKafkaClientSupplier()
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description org.apache.kafka.clients.admin.Admin
getAdmin(java.util.Map<java.lang.String,java.lang.Object> config)
Create anAdmin
which is used for internal topic management.org.apache.kafka.clients.admin.AdminClient
getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
Deprecated.org.apache.kafka.clients.consumer.Consumer<byte[],byte[]>
getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
Create aConsumer
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 aConsumer
which is used to consume records forGlobalKTable
.org.apache.kafka.clients.producer.Producer<byte[],byte[]>
getProducer(java.util.Map<java.lang.String,java.lang.Object> config)
Create aProducer
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 aConsumer
which is used to read records to restoreStateStore
s.
-
-
-
Method Detail
-
getAdminClient
@Deprecated public org.apache.kafka.clients.admin.AdminClient getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
Deprecated.Description copied from interface:KafkaClientSupplier
Create anAdminClient
which is used for internal topic management.- Specified by:
getAdminClient
in interfaceKafkaClientSupplier
- Parameters:
config
- Supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of
AdminClient
-
getAdmin
public org.apache.kafka.clients.admin.Admin getAdmin(java.util.Map<java.lang.String,java.lang.Object> config)
Description copied from interface:KafkaClientSupplier
Create anAdmin
which is used for internal topic management.- Specified by:
getAdmin
in interfaceKafkaClientSupplier
- Parameters:
config
- Supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of
Admin
-
getProducer
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> getProducer(java.util.Map<java.lang.String,java.lang.Object> config)
Description copied from interface:KafkaClientSupplier
Create aProducer
which is used to write records to sink topics.- Specified by:
getProducer
in interfaceKafkaClientSupplier
- Parameters:
config
-producer config
which is supplied by theProperties
given to theKafkaStreams
instance- Returns:
- an instance of Kafka producer
-
getConsumer
public org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
Description copied from interface:KafkaClientSupplier
Create aConsumer
which is used to read records of source topics.- Specified by:
getConsumer
in interfaceKafkaClientSupplier
- Parameters:
config
-consumer config
which is supplied by theProperties
given to theKafkaStreams
instance- Returns:
- an instance of Kafka consumer
-
getRestoreConsumer
public org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getRestoreConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
Description copied from interface:KafkaClientSupplier
Create aConsumer
which is used to read records to restoreStateStore
s.- Specified by:
getRestoreConsumer
in interfaceKafkaClientSupplier
- Parameters:
config
-restore consumer config
which is supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of Kafka consumer
-
getGlobalConsumer
public org.apache.kafka.clients.consumer.Consumer<byte[],byte[]> getGlobalConsumer(java.util.Map<java.lang.String,java.lang.Object> config)
Description copied from interface:KafkaClientSupplier
Create aConsumer
which is used to consume records forGlobalKTable
.- Specified by:
getGlobalConsumer
in interfaceKafkaClientSupplier
- Parameters:
config
-global consumer config
which is supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of Kafka consumer
-
-