Class TestKafkaVersion

    • Constructor Detail

      • TestKafkaVersion

        public TestKafkaVersion()
    • Method Detail

      • version

        public String version()
      • protocolVersion

        public String protocolVersion()
      • messageVersion

        public String messageVersion()
      • zookeeperVersion

        public String zookeeperVersion()
      • isDefault

        public boolean isDefault()
      • isSupported

        public boolean isSupported()
      • compareDottedVersions

        public int compareDottedVersions​(String version1,
                                         String version2)
        Compare two decimal version strings, e.g. 1.10.1 > 1.9.2
        Parameters:
        version1 - The first version.
        version2 - The second version.
        Returns:
        Zero if version1 == version2; -1 if version1 < version2; 1 if version1 > version2.
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • getKafkaVersionsInMap

        public static Map<String,​TestKafkaVersion> getKafkaVersionsInMap()
        Parse the version information present in the /kafka-versions classpath resource and return a map of kafka versions data with a version as key
        Returns:
        A map of the kafka versions listed in the kafka-versions.yaml file where key is specific version