Constant Field Values

io.krabka.*

io.krabka.streams.KrabkaStreamsConfig

Modifier and Type	Constant Field	Value
public static final String	GROUP_PROTOCOL_CONFIG	"group.protocol"
public static final String	STREAMS_GROUP_PROTOCOL	"streams"

io.krabka.streams.columnar.BlobCodec

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RECORD_BYTES	921600
public static final String	HEADERS_COLUMN	"__headers"
public static final String	KEY_COLUMN	"__key"
public static final String	OFFSET_COLUMN	"__offset"
public static final String	PARTITION_COLUMN	"__partition"
public static final String	TIMESTAMP_COLUMN	"__timestamp"

io.krabka.streams.columnar.BuiltinOp

Modifier and Type	Constant Field	Value
public static final String	WINDOW_END_COLUMN	"__window_end"
public static final String	WINDOW_START_COLUMN	"__window_start"

io.krabka.streams.columnar.ColumnarStateStore

Modifier and Type	Constant Field	Value
public static final long	LIVE_EPOCH	-1L

io.krabka.streams.columnar.GzipBatchCodec

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_UNCOMPRESSED_BYTES	16777216

io.krabka.streams.columnar.barrier.BarrierCutDecoder

Modifier and Type	Constant Field	Value
public static final String	TOPIC	"__barrier_state"

io.krabka.streams.coordination.CoordinationCodec

Modifier and Type	Constant Field	Value
public static final String	TOPIC	"__coordination_state"

io.krabka.streams.coordination.MemberId

Modifier and Type	Constant Field	Value
public static final int	MAX_LENGTH	249

io.krabka.streams.coordination.Role

Modifier and Type	Constant Field	Value
public static final int	MAX_LENGTH	249

io.krabka.streams.coordination.RolePartitioner

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_PARTITIONS	16

io.krabka.streams.schema.ConfluentWireFormat

Modifier and Type	Constant Field	Value
public static final byte	MAGIC	0x0