AI 助理
备案控制台
开发者社区 问答 正文

new FlinkKafkaConsumer010[String]("PREWARNING",new

new FlinkKafkaConsumer010[String]("PREWARNING",new JSONKeyValueDeserializationSchema(true), kafkaProps).setStartFromGroupOffsets() ) 我这样new 它说要我传个KeyedDeserializationSchema接口进去 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

展开
收起
黄一刀 2019-11-12 20:58:24 1740 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 黄二刀

    FlinkKafkaConsumer010不能跟泛型

    2019-11-12 20:58:54
    赞同 展开评论
问答分类：
开发者 云消息队列 Kafka 版 实时计算 Flink版
问答标签：
new String
问答地址：
开发者社区 > 云计算 > 问答
相关问答
"hello world" 和new String ("hello world") 有什么区别？
837
1
0
java里面String str = "" 和 new String()的区别在哪里？
690
1
0
有实例可以实现Java中使用new String()赋值吗？
705
1
0
String str="i"与 String str=new String("i")一样吗？
360
1
0
String str="i"与 String str=new String("i")一样吗？
510
1
0
new JSONObject(String)为什么报错?报错
1221
1
0
Java中"hello"直接量和new String("hello")有什么区别呢？
1043
1
0
String s = new String(“xyz”);创建了几个字符串对象?
1153
1
0
String str="i"与 String str=new String(“i”)一样吗？
1987
1
0
String s = new String("xyz");创建了几个字符串对象？
1253
2
0