updateReplicationInfo method

Future<UpdateReplicationInfoResponse> updateReplicationInfo({ required String currentVersion, required String replicatorArn, ConsumerGroupReplicationUpdate? consumerGroupReplication, LogDelivery? logDelivery, String? sourceKafkaClusterArn, String? sourceKafkaClusterId, String? targetKafkaClusterArn, String? targetKafkaClusterId, TopicReplicationUpdate? topicReplication, })

Updates replication info of a replicator.

May throw BadRequestException. May throw ForbiddenException. May throw InternalServerErrorException. May throw NotFoundException. May throw ServiceUnavailableException. May throw TooManyRequestsException. May throw UnauthorizedException.

Parameter currentVersion : Current replicator version.

Parameter replicatorArn : The Amazon Resource Name (ARN) of the replicator to be updated.

Parameter consumerGroupReplication : Updated consumer group replication information.

Parameter logDelivery : Configuration for delivering replicator logs to customer destinations.

Parameter sourceKafkaClusterArn : The ARN of the source Kafka cluster.

Parameter sourceKafkaClusterId : The ID of the source Kafka cluster.

Parameter targetKafkaClusterArn : The ARN of the target Kafka cluster.

Parameter targetKafkaClusterId : The ID of the target Kafka cluster.

Parameter topicReplication : Updated topic replication information.

Implementation

Future<UpdateReplicationInfoResponse> updateReplicationInfo({
  required String currentVersion,
  required String replicatorArn,
  ConsumerGroupReplicationUpdate? consumerGroupReplication,
  LogDelivery? logDelivery,
  String? sourceKafkaClusterArn,
  String? sourceKafkaClusterId,
  String? targetKafkaClusterArn,
  String? targetKafkaClusterId,
  TopicReplicationUpdate? topicReplication,
}) async {
  final $payload = <String, dynamic>{
    'currentVersion': currentVersion,
    if (consumerGroupReplication != null)
      'consumerGroupReplication': consumerGroupReplication,
    if (logDelivery != null) 'logDelivery': logDelivery,
    if (sourceKafkaClusterArn != null)
      'sourceKafkaClusterArn': sourceKafkaClusterArn,
    if (sourceKafkaClusterId != null)
      'sourceKafkaClusterId': sourceKafkaClusterId,
    if (targetKafkaClusterArn != null)
      'targetKafkaClusterArn': targetKafkaClusterArn,
    if (targetKafkaClusterId != null)
      'targetKafkaClusterId': targetKafkaClusterId,
    if (topicReplication != null) 'topicReplication': topicReplication,
  };
  final response = await _protocol.send(
    payload: $payload,
    method: 'PUT',
    requestUri:
        '/replication/v1/replicators/${Uri.encodeComponent(replicatorArn)}/replication-info',
    exceptionFnMap: _exceptionFns,
  );
  return UpdateReplicationInfoResponse.fromJson(response);
}