ApacheFlinkKafkaSource没有设置group.id
创始人
2024-09-05 19:30:17
0次

在Flink KafkaSource中设置ConsumerConfig.GROUP_ID_CONFIG参数可以解决该问题。例如：

FlinkKafkaConsumer011 kafkaSource = new FlinkKafkaConsumer011<>("topic", new SimpleStringSchema(), properties); kafkaSource.setStartFromLatest(); properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, "my-consumer-group-id"); //设置group.id

上一篇：ApacheFlinkKafkaSink序列化异常

下一篇：ApacheFlink流-流左外连接状态

相关内容

热门资讯

科技新动态！798大菠萝辅助，... 您好：798大菠萝辅助这款游戏可以开挂的，确实是有挂的，很多玩家在这款游戏中打牌都会发现很多用户的牌...
总算明白！堆金城陕西辅助器，德... 总算明白！堆金城陕西辅助器，德州局怎么透视，普及教程（有挂讲解）；总算明白！堆金城陕西辅助器，德州局...
玩家必看科普！博雅西苑曲靖棋牌... 玩家必看科普！博雅西苑曲靖棋牌辅助，聚星ai辅助工具收费多少，2025教程（有挂透明挂）；大家肯定在...
玩家必看科普！斗城麻将微信有没... 玩家必看科普！斗城麻将微信有没有挂，wepoker透视有没有，介绍教程（有挂头条）；致您一封信；亲爱...
新手必备！微乐辅助脚本，wpk... 新手必备！微乐辅助脚本，wpk显示有作弊，2025版教程（有挂辅助）是一款可以让一直输的玩家，快速成...
最新研发！常州茶苑辅助器下载，... 最新研发！常州茶苑辅助器下载，德普之星透视软件免费入口官网，德州论坛（有挂秘籍）;1、不需要AI权限...
总算清楚！奇迹免费脚本辅助工具... 总算清楚！奇迹免费脚本辅助工具，xpoker辅助工具，2025版教程（有挂方法）；亲真的是有正版授权...
今日科普！微乐小程序卡五星脚本... 今日科普！微乐小程序卡五星脚本，epoker底牌透视，2025新版技巧（有挂猫腻）;是一款可以让一直...
免费测试版！湖北休闲辅助，wp... 免费测试版！湖北休闲辅助，wpk软件是真的吗，透明挂教程（有挂方式）;湖北休闲辅助是一项湖北休闲辅助...
玩家必知教程！九天大厅挂价格，... 玩家必知教程！九天大厅挂价格，wepoker私局辅助，必胜教程（有挂工具）；致您一封信；亲爱九天大厅...