Package org.apache.kafka.streams.processor.internals

Class DefaultKafkaClientSupplier

java.lang.Object

org.apache.kafka.streams.processor.internals.DefaultKafkaClientSupplier

All Implemented Interfaces:

KafkaClientSupplier

public class DefaultKafkaClientSupplier
extends Object
implements KafkaClientSupplier

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaClientSupplier()

Method Summary

Modifier and Type	Method	Description
Admin	getAdmin(Map<String,Object> config)	Create an Admin which is used for internal topic management.
AdminClient	getAdminClient(Map<String,Object> config)	Deprecated.
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 StateStores.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultKafkaClientSupplier

public DefaultKafkaClientSupplier()

Method Detail

getAdminClient

@Deprecated
public AdminClient getAdminClient(Map<String,Object> config)

Deprecated.

Description copied from interface: KafkaClientSupplier

Create an AdminClient which is used for internal topic management.

Specified by:

getAdminClient in interface KafkaClientSupplier

Parameters:

config - Supplied by the Properties given to the KafkaStreams

Returns:

an instance of AdminClient

getAdmin

public Admin getAdmin(Map<String,Object> config)

Description copied from interface: KafkaClientSupplier

Create an Admin which is used for internal topic management.

Specified by:

getAdmin in interface KafkaClientSupplier

Parameters:

config - Supplied by the Properties given to the KafkaStreams

Returns:

an instance of Admin

getProducer

public Producer<byte[],byte[]> getProducer(Map<String,Object> config)

Description copied from interface: KafkaClientSupplier

Create a Producer which is used to write records to sink topics.

Specified by:

getProducer in interface KafkaClientSupplier

Parameters:

config - producer config which is supplied by the Properties given to the KafkaStreams instance

Returns:

an instance of Kafka producer

getConsumer

public Consumer<byte[],byte[]> getConsumer(Map<String,Object> config)

Description copied from interface: KafkaClientSupplier

Create a Consumer which is used to read records of source topics.

Specified by:

getConsumer in interface KafkaClientSupplier

Parameters:

config - consumer config which is supplied by the Properties given to the KafkaStreams instance

Returns:

an instance of Kafka consumer

getRestoreConsumer

public Consumer<byte[],byte[]> getRestoreConsumer(Map<String,Object> config)

Description copied from interface: KafkaClientSupplier

Create a Consumer which is used to read records to restore StateStores.

Specified by:

getRestoreConsumer in interface KafkaClientSupplier

Parameters:

config - restore consumer config which is supplied by the Properties given to the KafkaStreams

Returns:

an instance of Kafka consumer

getGlobalConsumer

public Consumer<byte[],byte[]> getGlobalConsumer(Map<String,Object> config)

Description copied from interface: KafkaClientSupplier

Create a Consumer which is used to consume records for GlobalKTable.

Specified by:

getGlobalConsumer in interface KafkaClientSupplier

Parameters:

config - global consumer config which is supplied by the Properties given to the KafkaStreams

Returns:

an instance of Kafka consumer