Hi, ALL
I'm trying and evaluating SeaTunnel's functionality, When testing
data sync from
Kafka to any sink database(e.g. Mysql, PG, clickhouse,,.etc, I find an
"issue" and it
may need to be enhanced.
The issue is that: the default key And/Or value's deserializer
when cosuming
Kafka records is [ByteArrayDeserializer] , Which means no matter you
override
"kakfa.config" or use default property in your job configuration file
the returned
data is byteArrays's binding(key,value).
This implement looks like a bit inconvenient because byeArrary is
not a
standard datatype in most polular databases and user must convert it
before writing data into database.
So, my question is: Do we have a plan to enhance it in future release ?
Thanks,
Leo
