Package org.apache.kafka.connect.connector.policy

Class ConnectorClientConfigRequest

java.lang.Object

org.apache.kafka.connect.connector.policy.ConnectorClientConfigRequest

public class ConnectorClientConfigRequest
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ConnectorClientConfigRequest.ClientType

Constructor Summary

Constructors

Constructor	Description
ConnectorClientConfigRequest(String connectorName, ConnectorType connectorType, Class<? extends Connector> connectorClass, Map<String,Object> clientProps, ConnectorClientConfigRequest.ClientType clientType)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	clientProps()	Provides configs with prefix "producer.override." for source connectors and also sink connectors that are configured with a DLQ topic.
ConnectorClientConfigRequest.ClientType	clientType()	ConnectorClientConfigRequest.ClientType.PRODUCER for ConnectorType.SOURCE
Class<? extends Connector>	connectorClass()	The class of the Connector.
String	connectorName()	Name of the connector specified in the connector config.
ConnectorType	connectorType()	Type of the Connector.

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectorClientConfigRequest

public ConnectorClientConfigRequest(String connectorName,
 ConnectorType connectorType,
 Class<? extends Connector> connectorClass,
 Map<String,Object> clientProps,
 ConnectorClientConfigRequest.ClientType clientType)

Method Details

clientProps

public Map<String,Object> clientProps()

Provides configs with prefix "producer.override." for source connectors and also sink connectors that are configured with a DLQ topic.

Provides configs with prefix "consumer.override." for sink connectors and also source connectors that are configured with a connector specific offsets topic (see KIP-618 for more details).

Provides configs with prefix "admin.override." for sink connectors configured with a DLQ topic and source connectors that are configured with exactly-once semantics, a connector specific offsets topic or topic creation enabled (see KIP-158 for more details).

Returns:

The client override properties specified in the Connector Config with prefix "producer.override.", "consumer.override." or "admin.override.". The returned configs don't include the prefixes.

clientType

public ConnectorClientConfigRequest.ClientType clientType()

ConnectorClientConfigRequest.ClientType.PRODUCER for ConnectorType.SOURCE

ConnectorClientConfigRequest.ClientType.CONSUMER for ConnectorType.SINK

ConnectorClientConfigRequest.ClientType.PRODUCER for DLQ in ConnectorType.SINK

ConnectorClientConfigRequest.ClientType.ADMIN for DLQ Topic Creation in ConnectorType.SINK

Returns:

enumeration specifying the client type that is being overridden by the worker; never null.

connectorName

public String connectorName()

Name of the connector specified in the connector config.

Returns:

name of the connector; never null.

connectorType

public ConnectorType connectorType()

Type of the Connector.

Returns:

enumeration specifying the type of the connector - ConnectorType.SINK or ConnectorType.SOURCE.

connectorClass

public Class<? extends Connector> connectorClass()

The class of the Connector.

Returns:

the class of the Connector being created; never null