Skip to content

Add support for generic message keys (e.g. message keys in Avro or JSON format, STRUCT) #824

@apurvam

Description

@apurvam

Right now, KSQL only uses a string Serde for keys in kafka messages. This works well for doing joins and aggregates on the entire key. However, in some cases a key (in json or avro or any other format) may have nested fields, and we may want to do joins and aggregates on a per field basis.

Further, by supporting structured keys, we can do filters on the fields of the keys as well.

This is related to #638 and #804.

We should also support non-string keys, such as Integer.

Metadata

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions