Documentation ¶
Index ¶
Constants ¶
View Source
const ( Code int8 = 1 DefaultCompressionLevel int = -1 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompressionCodec ¶
type CompressionCodec struct { // CompressionLevel is the level of compression to use on messages. CompressionLevel int }
func NewCompressionCodec ¶
func NewCompressionCodec() CompressionCodec
func NewCompressionCodecWith ¶
func NewCompressionCodecWith(level int) CompressionCodec
func (CompressionCodec) Code ¶
func (c CompressionCodec) Code() int8
Code implements the kafka.CompressionCodec interface.
Click to show internal directories.
Click to hide internal directories.