Update Replication Info

kafka_update_replication_info

R Documentation

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"
      )
    )
  )
)