[ https://issues.apache.org/jira/browse/FLINK-16689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-16689: ----------------------------------- Labels: stale-minor (was: ) > kafka connector as source get byte deserialize add support charsets > ------------------------------------------------------------------- > > Key: FLINK-16689 > URL: https://issues.apache.org/jira/browse/FLINK-16689 > Project: Flink > Issue Type: Improvement > Components: Connectors / Kafka > Affects Versions: 1.10.0 > Reporter: xiaodao > Priority: Minor > Labels: stale-minor > > some times kafkaProductor send record which is serialize with Specified > charsets eg: gbk, > and the consumer is not support to deserialize with Specified charsets. > just like: > org.apache.flink.formats.json.JsonRowDeserializationSchema#deserialize -- This message was sent by Atlassian Jira (v8.3.4#803005)