[
https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232726#comment-17232726
]
Timo Walther commented on FLINK-20170:
--
[~ana4] {{'connector.type' = 'kafka'}} uses
[
https://issues.apache.org/jira/browse/FLINK-20170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232709#comment-17232709
]
Mulan commented on FLINK-20170:
---
Could we add following code for fix this?
{code:java}
obj
