Aiven-Open/gcs-connector-for-apache-kafka

Use Json value and transforms

Closed this issue · 2 comments

Currently the connector expects the value converter to always be ByteArrayConverter.
This makes it difficult to use transforms that expect a Struct type.

Is it possible to use Json Converter or somehow allow transforms that expect a Struct type?

@ivanyu am i missing something or is this not possible at this time?

@paperboatinrain you're right, such limitation does exist: it's not possible to use other converters at this point. However, currently we're reworking how the data is processed and written in the connector. JSON and other formats will be surely supported.