ArroyoSystems / arroyo

Distributed stream processing engine in Rust
https://arroyo.dev
Apache License 2.0
3.45k stars 189 forks source link

Add support for serializing avro lists #576

Closed mwylde closed 3 months ago

mwylde commented 3 months ago

This was left as a todo in #481.

I've also done the (small) amount of work necessary to let users define lists in DDL, so for example this now works:

create table my_sink (
  f INT[]
) with (
  connector = 'kafka',
  ...
);