@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class ReplicationInfo extends Object implements Serializable, Cloneable, StructuredPojo
Specifies configuration for replication between a source and target Kafka cluster.
Constructor and Description |
---|
ReplicationInfo() |
Modifier and Type | Method and Description |
---|---|
ReplicationInfo |
clone() |
boolean |
equals(Object obj) |
ConsumerGroupReplication |
getConsumerGroupReplication()
Configuration relating to consumer group replication.
|
String |
getSourceKafkaClusterArn()
The ARN of the source Kafka cluster.
|
String |
getTargetCompressionType()
The compression type to use when producing records to target cluster.
|
String |
getTargetKafkaClusterArn()
The ARN of the target Kafka cluster.
|
TopicReplication |
getTopicReplication()
Configuration relating to topic replication.
|
int |
hashCode() |
void |
marshall(ProtocolMarshaller protocolMarshaller)
Marshalls this structured data using the given
ProtocolMarshaller . |
void |
setConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
|
void |
setSourceKafkaClusterArn(String sourceKafkaClusterArn)
The ARN of the source Kafka cluster.
|
void |
setTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
|
void |
setTargetKafkaClusterArn(String targetKafkaClusterArn)
The ARN of the target Kafka cluster.
|
void |
setTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
|
String |
toString()
Returns a string representation of this object.
|
ReplicationInfo |
withConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
|
ReplicationInfo |
withSourceKafkaClusterArn(String sourceKafkaClusterArn)
The ARN of the source Kafka cluster.
|
ReplicationInfo |
withTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
|
ReplicationInfo |
withTargetCompressionType(TargetCompressionType targetCompressionType)
The compression type to use when producing records to target cluster.
|
ReplicationInfo |
withTargetKafkaClusterArn(String targetKafkaClusterArn)
The ARN of the target Kafka cluster.
|
ReplicationInfo |
withTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
|
public void setConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
consumerGroupReplication
- Configuration relating to consumer group replication.public ConsumerGroupReplication getConsumerGroupReplication()
Configuration relating to consumer group replication.
public ReplicationInfo withConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
consumerGroupReplication
- Configuration relating to consumer group replication.public void setSourceKafkaClusterArn(String sourceKafkaClusterArn)
The ARN of the source Kafka cluster.
sourceKafkaClusterArn
- The ARN of the source Kafka cluster.public String getSourceKafkaClusterArn()
The ARN of the source Kafka cluster.
public ReplicationInfo withSourceKafkaClusterArn(String sourceKafkaClusterArn)
The ARN of the source Kafka cluster.
sourceKafkaClusterArn
- The ARN of the source Kafka cluster.public void setTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
targetCompressionType
- The compression type to use when producing records to target cluster.TargetCompressionType
public String getTargetCompressionType()
The compression type to use when producing records to target cluster.
TargetCompressionType
public ReplicationInfo withTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
targetCompressionType
- The compression type to use when producing records to target cluster.TargetCompressionType
public ReplicationInfo withTargetCompressionType(TargetCompressionType targetCompressionType)
The compression type to use when producing records to target cluster.
targetCompressionType
- The compression type to use when producing records to target cluster.TargetCompressionType
public void setTargetKafkaClusterArn(String targetKafkaClusterArn)
The ARN of the target Kafka cluster.
targetKafkaClusterArn
- The ARN of the target Kafka cluster.public String getTargetKafkaClusterArn()
The ARN of the target Kafka cluster.
public ReplicationInfo withTargetKafkaClusterArn(String targetKafkaClusterArn)
The ARN of the target Kafka cluster.
targetKafkaClusterArn
- The ARN of the target Kafka cluster.public void setTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
topicReplication
- Configuration relating to topic replication.public TopicReplication getTopicReplication()
Configuration relating to topic replication.
public ReplicationInfo withTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
topicReplication
- Configuration relating to topic replication.public String toString()
toString
in class Object
Object.toString()
public ReplicationInfo clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.