You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Similar to upsert-avro, user can specify the encoding as protobuf.
Upsert bytes
While upsert bytes does not use the same syntax as other upsert formats, user can implement the same semantic with the include key as clause and specifying the Kafka key as the primary key.
CREATETABLEt (
data BYTEA, PRIMARY KEY (rw_key)
) INCLUDE key AS rw_key
WITH ( ... )
FORMAT PLAIN ENCODE BYTES
Additional Suggestion:
I suggest further dividing the source formats catalog into 3 main types:
Append-only
Avro
JSON
Protobuf
Bytes
Upsert
Upsert Avro, JSON and Protobuf
Upsert Bytes
CDC
Debezium AVRO
Canal JSON
Debezium JSON
Debezium MongoDB JSON
Maxwell JSON
The text was updated successfully, but these errors were encountered:
Where the document should be updated:
https://docs.risingwave.com/ingestion/supported-sources-and-formats
The current documentation only covers Upsert JSON and Upsert Avro, but it lacks guides for Upsert Protobuf and Upsert Bytes.
Upsert protobuf:
Last update can be found in risingwavelabs/risingwave#11047
Similar to upsert-avro, user can specify the encoding as protobuf.
Upsert bytes
While
upsert bytes
does not use the same syntax as other upsert formats, user can implement the same semantic with theinclude key as
clause and specifying the Kafka key as the primary key.Additional Suggestion:
I suggest further dividing the source formats catalog into 3 main types:
The text was updated successfully, but these errors were encountered: