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 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.SOURCEConnectorClientConfigRequest.ClientType.CONSUMER for ConnectorType.SINKConnectorClientConfigRequest.ClientType.PRODUCER for DLQ in ConnectorType.SINKConnectorClientConfigRequest.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