(t *testing.T)
| 32 | } |
| 33 | |
| 34 | func TestCodecs(t *testing.T) { |
| 35 | for i, c := range pkg.Codecs { |
| 36 | if c != nil { |
| 37 | if code := c.Code(); int8(code) != int8(i) { |
| 38 | t.Fatal("default compression codec table is misconfigured for", c.Name()) |
| 39 | } |
| 40 | } |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | func TestCompression(t *testing.T) { |
| 45 | msg := kafka.Message{ |