Updates replication info of a replicator¶

Description¶

Updates replication info of a replicator.

Usage¶

kafka_update_replication_info(ConsumerGroupReplication, CurrentVersion,
  ReplicatorArn, SourceKafkaClusterArn, SourceKafkaClusterId,
  TargetKafkaClusterArn, TargetKafkaClusterId, TopicReplication,
  LogDelivery)

Arguments¶

ConsumerGroupReplication

Updated consumer group replication information.
CurrentVersion

[required] Current replicator version.
ReplicatorArn

[required] The Amazon Resource Name (ARN) of the replicator to be updated.
SourceKafkaClusterArn

The ARN of the source Kafka cluster.
SourceKafkaClusterId

The ID of the source Kafka cluster.
TargetKafkaClusterArn

The ARN of the target Kafka cluster.
TargetKafkaClusterId

The ID of the target Kafka cluster.
TopicReplication

Updated topic replication information.
LogDelivery

Configuration for delivering replicator logs to customer destinations.

Value¶

A list with the following syntax:

list(
  ReplicatorArn = "string",
  ReplicatorState = "RUNNING"|"CREATING"|"UPDATING"|"DELETING"|"FAILED"
)

Request syntax¶

svc$update_replication_info(
  ConsumerGroupReplication = list(
    ConsumerGroupsToExclude = list(
      "string"
    ),
    ConsumerGroupsToReplicate = list(
      "string"
    ),
    DetectAndCopyNewConsumerGroups = TRUE|FALSE,
    SynchroniseConsumerGroupOffsets = TRUE|FALSE
  ),
  CurrentVersion = "string",
  ReplicatorArn = "string",
  SourceKafkaClusterArn = "string",
  SourceKafkaClusterId = "string",
  TargetKafkaClusterArn = "string",
  TargetKafkaClusterId = "string",
  TopicReplication = list(
    CopyAccessControlListsForTopics = TRUE|FALSE,
    CopyTopicConfigurations = TRUE|FALSE,
    DetectAndCopyNewTopics = TRUE|FALSE,
    TopicsToExclude = list(
      "string"
    ),
    TopicsToReplicate = list(
      "string"
    )
  ),
  LogDelivery = list(
    ReplicatorLogDelivery = list(
      CloudWatchLogs = list(
        Enabled = TRUE|FALSE,
        LogGroup = "string"
      ),
      Firehose = list(
        Enabled = TRUE|FALSE,
        DeliveryStream = "string"
      ),
      S3 = list(
        Enabled = TRUE|FALSE,
        Bucket = "string",
        Prefix = "string"
      )
    )
  )
)