Class ReplicatorKafkaCluster


  • public final class ReplicatorKafkaCluster
    extends java.lang.Object
    • Method Detail

      • amazonMskCluster

        public java.util.Optional<ReplicatorKafkaClusterAmazonMskCluster> amazonMskCluster()
        Returns:
        Details of an Amazon MSK cluster. Exactly one of `amazonMskCluster` or `apacheKafkaCluster` must be specified. See `amazonMskCluster` Block below.
      • apacheKafkaCluster

        public java.util.Optional<ReplicatorKafkaClusterApacheKafkaCluster> apacheKafkaCluster()
        Returns:
        Details of a self-managed or on-premises Apache Kafka cluster. Exactly one of `amazonMskCluster` or `apacheKafkaCluster` must be specified. See `apacheKafkaCluster` Block below.
      • clientAuthentication

        public java.util.Optional<ReplicatorKafkaClusterClientAuthentication> clientAuthentication()
        Returns:
        Details of the client authentication used by the Kafka cluster. Only valid for an `apacheKafkaCluster`. See `clientAuthentication` Block below.
      • encryptionInTransit

        public java.util.Optional<ReplicatorKafkaClusterEncryptionInTransit> encryptionInTransit()
        Returns:
        Details of encryption in transit to the Kafka cluster. Only valid for an `apacheKafkaCluster`. TLS encryption in transit is always applied to an `apacheKafkaCluster`; this block is only required to supply a custom root CA chain (for a cluster using a private or self-signed certificate). See `encryptionInTransit` Block below.
      • vpcConfig

        public java.util.Optional<ReplicatorKafkaClusterVpcConfig> vpcConfig()
        Returns:
        Details of an Amazon VPC which has network connectivity to the Kafka cluster. Provide this on the `amazonMskCluster` entry only; the replicator reaches the Apache Kafka cluster through that VPC. See `vpcConfig` Block below.