@Generated(value="com.amazonaws:aws-java-sdk-code-generator") public class ReplicationInfoDescription extends Object implements Serializable, Cloneable, StructuredPojo
Specifies configuration for replication between a source and target Kafka cluster (sourceKafkaClusterAlias -> targetKafkaClusterAlias)
Constructor and Description |
---|
ReplicationInfoDescription() |
Modifier and Type | Method and Description |
---|---|
ReplicationInfoDescription |
clone() |
boolean |
equals(Object obj) |
ConsumerGroupReplication |
getConsumerGroupReplication()
Configuration relating to consumer group replication.
|
String |
getSourceKafkaClusterAlias()
The alias of the source Kafka cluster.
|
String |
getTargetCompressionType()
The compression type to use when producing records to target cluster.
|
String |
getTargetKafkaClusterAlias()
The alias 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 |
setSourceKafkaClusterAlias(String sourceKafkaClusterAlias)
The alias of the source Kafka cluster.
|
void |
setTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
|
void |
setTargetKafkaClusterAlias(String targetKafkaClusterAlias)
The alias of the target Kafka cluster.
|
void |
setTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
|
String |
toString()
Returns a string representation of this object.
|
ReplicationInfoDescription |
withConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
|
ReplicationInfoDescription |
withSourceKafkaClusterAlias(String sourceKafkaClusterAlias)
The alias of the source Kafka cluster.
|
ReplicationInfoDescription |
withTargetCompressionType(String targetCompressionType)
The compression type to use when producing records to target cluster.
|
ReplicationInfoDescription |
withTargetCompressionType(TargetCompressionType targetCompressionType)
The compression type to use when producing records to target cluster.
|
ReplicationInfoDescription |
withTargetKafkaClusterAlias(String targetKafkaClusterAlias)
The alias of the target Kafka cluster.
|
ReplicationInfoDescription |
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 ReplicationInfoDescription withConsumerGroupReplication(ConsumerGroupReplication consumerGroupReplication)
Configuration relating to consumer group replication.
consumerGroupReplication
- Configuration relating to consumer group replication.public void setSourceKafkaClusterAlias(String sourceKafkaClusterAlias)
The alias of the source Kafka cluster.
sourceKafkaClusterAlias
- The alias of the source Kafka cluster.public String getSourceKafkaClusterAlias()
The alias of the source Kafka cluster.
public ReplicationInfoDescription withSourceKafkaClusterAlias(String sourceKafkaClusterAlias)
The alias of the source Kafka cluster.
sourceKafkaClusterAlias
- The alias 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 ReplicationInfoDescription 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 ReplicationInfoDescription 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 setTargetKafkaClusterAlias(String targetKafkaClusterAlias)
The alias of the target Kafka cluster.
targetKafkaClusterAlias
- The alias of the target Kafka cluster.public String getTargetKafkaClusterAlias()
The alias of the target Kafka cluster.
public ReplicationInfoDescription withTargetKafkaClusterAlias(String targetKafkaClusterAlias)
The alias of the target Kafka cluster.
targetKafkaClusterAlias
- The alias 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 ReplicationInfoDescription withTopicReplication(TopicReplication topicReplication)
Configuration relating to topic replication.
topicReplication
- Configuration relating to topic replication.public String toString()
toString
in class Object
Object.toString()
public ReplicationInfoDescription clone()
public void marshall(ProtocolMarshaller protocolMarshaller)
StructuredPojo
ProtocolMarshaller
.marshall
in interface StructuredPojo
protocolMarshaller
- Implementation of ProtocolMarshaller
used to marshall this object's data.