弥生i 2021-07-08 17:02 采纳率: 75%
浏览 202
已结题

FlinkKafkaConsumer09忽略key、value反序列化配置

我手动配置了StringDeserializer，启动任务后还是ByteArrayDeserializer，日志报错为
2021-07-08 16:57:12 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 -Ignoring configured key DeSerializer (key.deserializer)
2021-07-08 16:57:12 WARN org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 -Ignoring configured value DeSerializer (value.deserializer)
FlinkKafkaConsumer09忽略了反序列化配置这是什么问题呢，有大佬知道吗

  • 写回答

3条回答 默认 最新

  • 弥生i 2023-06-20 11:30
    关注

    这个问题需要修改引用的类，然后打包替换掉该类

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(2条)

报告相同问题？

  • Apache Flink Java 示例：实时温度监控（连接流）
    2025-07-15 15:35
    csdn_tom_168的博客 Apache Flink Java 示例：实时温度监控（连接流） 本示例展示如何使用 Apache Flink 的连接流(ConnectedStreams)功能实现实时温度监控系统。该系统将处理两种数据流：温度传感器数据和设备告警规则数据，实现动态...
  • Flink Java 之 读取 kafka 数据与数据写入 kafka
    2022-07-04 08:42
    lynn.lin的博客 序列与反序列化 kafka 数据 Flink Kafka Consumer 需要知道如何将 Kafka 中的二进制数据转换为 Java 或者 Scala 对象。KafkaDeserializationSchema 允许用户指定这样的 schema，每条 Kafka 中的消息会反序列化。 ...
  • Java开发：从入门到精通
    2025-07-17 16:12
    幻云2010的博客 代码，是思想的显化，是逻辑的禅定。本书将带您从“万物皆对象”的初心出发，掌握Java核心，驰骋于Spring的广阔天地，构建微服务的坛城，乃至驾驭AI的智慧之光。莫将此书仅作技术图谱，它更是一张心法地图。愿您于此...
  • flink java
    2022-04-14 23:23
    东河西的博客 这里写目录标题5. Flink流处理API5.1 Environment执行环境5.2 Source数据...基于key的分组转换keyBy()指定key的三种方式聚合（Aggregation）算子reduce归并三 多数据流转换ConnectUnion合流和Connect的区别？四 数据重
  • FlinkKafkaConsumer
    2021-04-06 11:33
    橘子洲头无桔子的博客 // kafka 消息的value序列化器 props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); // 指定kafka的消费者从哪里开始消费数据 // 共有三种方式， // #earliest // 当各...
  • Java构建数字孪生工厂全流程解析，90%的人都忽略了这2个致命细节
    2025-10-12 14:54
    InstrIsle的博客 掌握Java工业元宇宙应用核心方法，解析数字孪生工厂构建全流程。涵盖设备建模、实时数据同步等关键场景，揭示90%开发者忽略的性能优化与系统集成细节。提升工业仿真效率与稳定性，值得收藏。
  • 提示工程测试自动化平台的API监控：架构师的接口稳定性保障
    2025-11-07 19:04
    AI移动开发前沿的博客 张三，资深软件架构师，专注于AI应用架构设计与测试自动化，拥有10年以上的互联网行业经验。曾主导多个大型AI项目的架构设计，包括电商AI客服系统、智能推荐系统等。擅长将复杂的技术概念转化为可落地的解决方案，...
  • Flink Connector（一） FlinkKafkaConsumer
    2021-02-28 17:07
    OOM先生的博客 FlinkKafkaConsumer Maven依赖： <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.11</artifactId> <version>1...
  • Apache Flink错误处理实战手册：2年生产环境调试经验总结
    2025-08-27 16:22
    Apache Flink的博客 本文由 Ververica 客户成功经理 Naci ...内容涵盖 Kafka 连接器迁移导致的状态管理问题、任务槽负载不均问题以及 Kryo 序列化引发的性能陷阱，旨在帮助企业开发者避免常见误区，提升实时流处理系统的稳定性与性能。
  • Java开发 微不足道的知识点
    2020-10-29 17:04
    Jasper·Deng的博客 两年开发经验的java开发应该哪些知识点？ 或者说，该如何学习java开发？ 下面我总结了一下自己的复习的思路，从JVM到分布式 （以下都是主要的知识点，已省略Mybatis、Hibernate等框架） 复习提纲 文章目录一、JVM1....
  • 没有解决我的问题, 去提问

问题事件

  • 系统已结题 6月28日
  • 已采纳回答 6月20日