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 class
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<String,Object>
clientProps()
Provides Config with prefixproducer.override.
forConnectorType.SOURCE
.ConnectorClientConfigRequest.ClientType
clientType()
ConnectorClientConfigRequest.ClientType.PRODUCER
forConnectorType.SOURCE
ConnectorClientConfigRequest.ClientType.CONSUMER
forConnectorType.SINK
ConnectorClientConfigRequest.ClientType.PRODUCER
for DLQ inConnectorType.SINK
ConnectorClientConfigRequest.ClientType.ADMIN
for DLQ Topic Creation inConnectorType.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.
-
-
-
Constructor Detail
-
ConnectorClientConfigRequest
public ConnectorClientConfigRequest(String connectorName, ConnectorType connectorType, Class<? extends Connector> connectorClass, Map<String,Object> clientProps, ConnectorClientConfigRequest.ClientType clientType)
-
-
Method Detail
-
clientProps
public Map<String,Object> clientProps()
Provides Config with prefixproducer.override.
forConnectorType.SOURCE
. Provides Config with prefixconsumer.override.
forConnectorType.SINK
. Provides Config with prefixproducer.override.
forConnectorType.SINK
for DLQ. Provides Config with prefixadmin.override.
forConnectorType.SINK
for DLQ.- Returns:
- The client properties specified in the Connector Config with prefix
producer.override.
,consumer.override.
andadmin.override.
. The configs don't include the prefixes.
-
clientType
public ConnectorClientConfigRequest.ClientType clientType()
ConnectorClientConfigRequest.ClientType.PRODUCER
forConnectorType.SOURCE
ConnectorClientConfigRequest.ClientType.CONSUMER
forConnectorType.SINK
ConnectorClientConfigRequest.ClientType.PRODUCER
for DLQ inConnectorType.SINK
ConnectorClientConfigRequest.ClientType.ADMIN
for DLQ Topic Creation inConnectorType.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
orConnectorType.SOURCE
.
-
-