Function javaProducerArgs

functional_java_interop_test.go:274–283

(topic string, codec CompressionCodec)

}

func javaProducerArgs(topic string, codec CompressionCodec) []string {
	args := make([]string, 0, 8)
	if kafkaVersionAtLeast("2.5.0") {
		args = append(args, "--bootstrap-server", brokerAddr)
	} else {
		args = append(args, "--broker-list", brokerAddr)
	}
	args = append(args, "--topic", topic)
	return append(args, javaProducerCompressionArgs(codec)...)
}

func javaProducerCompressionArgs(codec CompressionCodec) []string {
	if kafkaVersionAtLeast("0.10.0") {