Function javaProducerCompressionArgs

functional_java_interop_test.go:285–290

(codec CompressionCodec)

}

func javaProducerCompressionArgs(codec CompressionCodec) []string {
	if kafkaVersionAtLeast("0.10.0") {
		return []string{"--producer-property", fmt.Sprintf("compression.type=%s", codec.String())}
	}
	return []string{"--compression-codec", codec.String()}
}

func javaConsumerArgs(topic string, startOffset int64, count int) []string {
	args := make([]string, 0, 12)