在使用IDEA开发flink-kafka时,设置
setStartingOffsets(OffsetsInitializer.earliest())时,发现标红,不能引用。
在这里插入图片描述
查看异常报文:
在这里插入图片描述
Static interface method calls are not supported at language level ‘5’。
语言级别5,不支持静态方法引用。
修改语言级别,我的jdk是8,我就相应的改为了8,问题就解决了。
在这里插入图片描述

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐