Class RepushInfo


  • public class RepushInfo
    extends java.lang.Object
    • Constructor Detail

      • RepushInfo

        public RepushInfo()
    • Method Detail

      • createRepushInfo

        public static RepushInfo createRepushInfo​(Version version,
                                                  java.lang.String kafkaBrokerUrl,
                                                  java.lang.String systemSchemaClusterD2ServiceName,
                                                  java.lang.String systemSchemaClusterD2ZkHost)
      • setVersion

        public void setVersion​(Version version)
      • setKafkaBrokerUrl

        public void setKafkaBrokerUrl​(java.lang.String kafkaBrokerUrl)
      • setSystemSchemaClusterD2ServiceName

        public void setSystemSchemaClusterD2ServiceName​(java.lang.String systemSchemaClusterD2ServiceName)
      • setSystemSchemaClusterD2ZkHost

        public void setSystemSchemaClusterD2ZkHost​(java.lang.String systemSchemaClusterD2ZkHost)
      • getKafkaBrokerUrl

        public java.lang.String getKafkaBrokerUrl()
      • getVersion

        public Version getVersion()
      • getSystemSchemaClusterD2ServiceName

        public java.lang.String getSystemSchemaClusterD2ServiceName()
      • getSystemSchemaClusterD2ZkHost

        public java.lang.String getSystemSchemaClusterD2ZkHost()