KafkaConnect / Client / create_worker_configuration

create_worker_configuration

KafkaConnect.Client.create_worker_configuration(**kwargs)

Creates a worker configuration using the specified properties.

See also: AWS API Documentation

Request Syntax

response = client.create_worker_configuration(
    description='string',
    name='string',
    propertiesFileContent='string',
    tags={
        'string': 'string'
    }
)

Parameters:

• description (string) – A summary description of the worker configuration.

• name (string) –

  [REQUIRED]

  The name of the worker configuration.

• propertiesFileContent (string) –

  [REQUIRED]

  Base64 encoded contents of connect-distributed.properties file.

• tags (dict) –

  The tags you want to attach to the worker configuration.

  • (string) –

    • (string) –

Return type:

dict

Returns:

Response Syntax

{
    'creationTime': datetime(2015, 1, 1),
    'latestRevision': {
        'creationTime': datetime(2015, 1, 1),
        'description': 'string',
        'revision': 123
    },
    'name': 'string',
    'workerConfigurationArn': 'string',
    'workerConfigurationState': 'ACTIVE'|'DELETING'
}

Response Structure

• (dict) –

  • creationTime (datetime) –

    The time that the worker configuration was created.

  • latestRevision (dict) –

    The latest revision of the worker configuration.

    • creationTime (datetime) –

      The time that a worker configuration revision was created.

    • description (string) –

      The description of a worker configuration revision.

    • revision (integer) –

      The revision of a worker configuration.

  • name (string) –

    The name of the worker configuration.

  • workerConfigurationArn (string) –

    The Amazon Resource Name (ARN) that Amazon assigned to the worker configuration.

  • workerConfigurationState (string) –

    The state of the worker configuration.

Exceptions

• KafkaConnect.Client.exceptions.NotFoundException

• KafkaConnect.Client.exceptions.ConflictException

• KafkaConnect.Client.exceptions.BadRequestException

• KafkaConnect.Client.exceptions.ForbiddenException

• KafkaConnect.Client.exceptions.ServiceUnavailableException

• KafkaConnect.Client.exceptions.TooManyRequestsException

• KafkaConnect.Client.exceptions.UnauthorizedException

• KafkaConnect.Client.exceptions.InternalServerErrorException