[ https://issues.apache.org/jira/browse/FLINK-16689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321395#comment-17321395 ]
Flink Jira Bot commented on FLINK-16689: ---------------------------------------- This issue and all of its Sub-Tasks have not been updated for 180 days. So, it has been labeled "stale-minor". If you are still affected by this bug or are still interested in this issue, please give an update and remove the label. In 7 days the issue will be closed automatically. > 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)