Function kafkaVersionAtLeast

functional_java_interop_test.go:266–272

(requiredVersion string)

}

func kafkaVersionAtLeast(requiredVersion string) bool {
	kafkaVersion := FunctionalTestEnv.KafkaVersion
	if kafkaVersion == "" {
		return false
	}
	return parseKafkaVersion(kafkaVersion).satisfies(parseKafkaVersion(requiredVersion))
}

func javaProducerArgs(topic string, codec CompressionCodec) []string {
	args := make([]string, 0, 8)