kubeshark/tap/extensions/kafka/compression.go
2022-02-01 12:08:55 +02:00

13 lines
270 B
Go

package kafka
import (
"github.com/segmentio/kafka-go/compress"
)
type Compression = compress.Compression
type CompressionCodec = compress.Codec
// TODO: this file should probably go away once the internals of the package
// have moved to use the protocol package.