(t *testing.T)
| 41 | } |
| 42 | |
| 43 | func TestFuncProducingZstd(t *testing.T) { |
| 44 | config := NewFunctionalTestConfig() |
| 45 | config.Producer.Compression = CompressionZSTD |
| 46 | testProducingMessages(t, config, V2_1_0_0) // must be at least 2.1.0.0 for zstd |
| 47 | } |
| 48 | |
| 49 | func TestFuncProducingNoResponse(t *testing.T) { |
| 50 | config := NewFunctionalTestConfig() |
nothing calls this directly
no test coverage detected