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 Config with prefix producer.override. for ConnectorType.SOURCE.
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
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 Config with prefix producer.override. for ConnectorType.SOURCE. Provides Config with prefix consumer.override. for ConnectorType.SINK. Provides Config with prefix producer.override. for ConnectorType.SINK for DLQ. Provides Config with prefix admin.override. for ConnectorType.SINK for DLQ.

Returns:

The client properties specified in the Connector Config with prefix producer.override. , consumer.override. and admin.override.. The 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 overriden 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