Package org.apache.kafka.streams
Interface KafkaClientSupplier
-
- All Known Implementing Classes:
DefaultKafkaClientSupplier
public interface KafkaClientSupplier
KafkaClientSupplier
can be used to provide custom Kafka clients to aKafkaStreams
instance.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default 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.default org.apache.kafka.clients.admin.AdminClient
getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
Deprecated.Not called by Kafka Streams, which now usesgetAdmin(java.util.Map<java.lang.String, java.lang.Object>)
instead.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 default org.apache.kafka.clients.admin.AdminClient getAdminClient(java.util.Map<java.lang.String,java.lang.Object> config)
Deprecated.Not called by Kafka Streams, which now usesgetAdmin(java.util.Map<java.lang.String, java.lang.Object>)
instead.Create anAdminClient
which is used for internal topic management.- Parameters:
config
- Supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of
AdminClient
-
getAdmin
default 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.- Parameters:
config
- Supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of
Admin
-
getProducer
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.- Parameters:
config
-producer config
which is supplied by theProperties
given to theKafkaStreams
instance- Returns:
- an instance of Kafka producer
-
getConsumer
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.- Parameters:
config
-consumer config
which is supplied by theProperties
given to theKafkaStreams
instance- Returns:
- an instance of Kafka consumer
-
getRestoreConsumer
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.- Parameters:
config
-restore consumer config
which is supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of Kafka consumer
-
getGlobalConsumer
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
.- Parameters:
config
-global consumer config
which is supplied by theProperties
given to theKafkaStreams
- Returns:
- an instance of Kafka consumer
-
-