Skip to content

Commit

Permalink
Update docs
Browse files Browse the repository at this point in the history
  • Loading branch information
rjobanp committed Jul 15, 2024
1 parent 523d2b0 commit 1cc02bc
Show file tree
Hide file tree
Showing 5 changed files with 245 additions and 192 deletions.
7 changes: 7 additions & 0 deletions doc/user/content/sql/create-source/kafka.md
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,13 @@ for the given Kafka message key cannot be decoded, this `error` column will cont
the error message. If the most recent value for a key has been successfully decoded,
this column will be `NULL`.

To use an alternative name for the error column, use `INLINE AS ..` to specify the
column name to use:

```mzsql
ENVELOPE UPSERT (VALUE DECODING ERRORS = (INLINE AS my_error_col))
```

It might be convenient to implement a parsing view on top of your Kafka upsert source that
excludes keys with decoding errors:

Expand Down
Loading

0 comments on commit 1cc02bc

Please sign in to comment.