update_connector
(**kwargs)¶Updates the specified connector.
See also: AWS API Documentation
Request Syntax
response = client.update_connector(
capacity={
'autoScaling': {
'maxWorkerCount': 123,
'mcuCount': 123,
'minWorkerCount': 123,
'scaleInPolicy': {
'cpuUtilizationPercentage': 123
},
'scaleOutPolicy': {
'cpuUtilizationPercentage': 123
}
},
'provisionedCapacity': {
'mcuCount': 123,
'workerCount': 123
}
},
connectorArn='string',
currentVersion='string'
)
[REQUIRED]
The target capacity.
The target auto scaling setting.
The target maximum number of workers allocated to the connector.
The target number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8.
The target minimum number of workers allocated to the connector.
The target sacle-in policy for the connector.
The target CPU utilization percentage threshold at which you want connector scale in to be triggered.
The target sacle-out policy for the connector.
The target CPU utilization percentage threshold at which you want connector scale out to be triggered.
The target settings for provisioned capacity.
The number of microcontroller units (MCUs) allocated to each connector worker. The valid values are 1,2,4,8.
The number of workers that are allocated to the connector.
[REQUIRED]
The Amazon Resource Name (ARN) of the connector that you want to update.
[REQUIRED]
The current version of the connector that you want to update.
dict
Response Syntax
{
'connectorArn': 'string',
'connectorState': 'RUNNING'|'CREATING'|'UPDATING'|'DELETING'|'FAILED'
}
Response Structure
(dict) --
connectorArn (string) --
The Amazon Resource Name (ARN) of the connector.
connectorState (string) --
The state of the connector.
Exceptions
KafkaConnect.Client.exceptions.NotFoundException
KafkaConnect.Client.exceptions.BadRequestException
KafkaConnect.Client.exceptions.ForbiddenException
KafkaConnect.Client.exceptions.ServiceUnavailableException
KafkaConnect.Client.exceptions.TooManyRequestsException
KafkaConnect.Client.exceptions.UnauthorizedException
KafkaConnect.Client.exceptions.InternalServerErrorException