IngestRow is a convenience method which encodes the row into a Kafka message first, then ingests it.

IngestRows ingests rows given schema and source name - convenience method for use in tests.

Float32BEKeyTLJSONValueEncoder encodes as float32BE key, top level JSON value, no headers.

Float64BEKeyTLJSONValueEncoder encodes as float64BE key, top level JSON value, no headers.

Int16BEKeyTLJSONValueEncoder encodes as int16BE key, top level JSON value, no headers.

Int32BEKeyTLJSONValueEncoder encodes as int32BE key, top level JSON value, no headers.

Int64BEKeyTLJSONValueEncoder encodes as int64BE key, top level JSON value, no headers.

JSONHeadersEncoder puts the message key encoded as JSON in one header and the message value encoded as JSON in another, the actual message key and value are empty JSON objects.

JSONKeyJSONValueEncoder encodes as top level JSON key, top level JSON value, no headers.

NestedJSONKeyNestedJSONValueEncoder encodes as nested JSON key, nested JSON value, no headers.

StringKeyProtobufValueEncoder is an encoder that translates each row to a protobuf message.

StringKeyTLJSONValueEncoder encodes as string key, top level JSON value, no headers.