@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 ReplicationInfoDescription()
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.