Function TestJavaProducerCompressionRoundTrip

functional_java_interop_test.go:217–238

TestJavaProducerCompressionRoundTrip tests that messages produced by Kafka's Java console producer with various compression codecs can be correctly consumed and decompressed by Sarama.

(t *testing.T)

// console producer with various compression codecs can be correctly consumed and
// decompressed by Sarama.
func TestJavaProducerCompressionRoundTrip(t *testing.T) {
	setupFunctionalTest(t)
	defer teardownFunctionalTest(t)

	for _, tc := range compressionTests {
		t.Run(tc.codec.String(), func(t *testing.T) {
			checkKafkaVersion(t, tc.minKafka)

			expected := []string{
				fmt.Sprintf("Message 1 with %s compression", tc.codec),
				"Message 2",
				"Message 3",
			}

			initialOffset := endOffsetForPartition(t, "test.1", 0)
			produceWithJava(t, "test.1", tc.codec, expected)
			actual := consumeWithSarama(t, "test.1", initialOffset, len(expected))

			require.Equal(t, expected, actual)
		})
	}
}

// TestJavaConsumerCompressionRoundTrip tests that messages produced by Sarama
// with various compression codecs can be correctly consumed and decompressed