我手动配置了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忽略了反序列化配置这是什么问题呢，有大佬知道吗
FlinkKafkaConsumer09忽略key、value反序列化配置
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
3条回答 默认 最新
- 弥生i 2023-06-20 11:30关注
这个问题需要修改引用的类，然后打包替换掉该类
本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏举报 分享
- 2022-05-25 22:20回答 2 已采纳 参考下 不懂问我，有用采纳一手 String data = "name=刘小溪&sport=篮球&sport=逛街&sex=女&fruit=苹果&fruit=梨子&fruit=杏";
- 2020-11-25 09:23回答 2 已采纳 你的data里面用的是relationsku，SeckillSesssionsWithSkus里面的是relationSkus，一个小写s，一个大写S
- 2015-06-21 06:29回答 3 已采纳 http://www.cnblogs.com/guanghuiqq/archive/2012/07/18/2597036.html
- 2022-07-04 08:42Lynn Gin的博客 序列与反序列化 kafka 数据 Flink Kafka Consumer 需要知道如何将 Kafka 中的二进制数据转换为 Java 或者 Scala 对象。KafkaDeserializationSchema 允许用户指定这样的 schema，每条 Kafka 中的消息会反序列化。 ...
- 2022-05-07 14:46回答 2 已采纳 json字符串含有数组，核查下反序列化接收对象是否定义对应类型的参数 例如： //反序列化方法 public static <T> T decode(String json, Ty
- 2021-05-14 18:22回答 5 已采纳 可以通过重载QDataStream类，具体方法参考： https://blog.csdn.net/houqd2012/article/details/25070987 https://blog.c
- 2021-05-19 20:19回答 4 已采纳 https://zhidao.baidu.com/question/181759229316819524.html 参考这篇文章
- 2021-04-06 11:33橘子洲头无桔子的博客 // kafka 消息的value序列化器 props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer"); // 指定kafka的消费者从哪里开始消费数据 // 共有三种方式， // #earliest // 当各...
- 2022-01-17 11:07回答 2 已采纳 自己记录一下吧，不知哪位大神有简单的方式。 ```java //文件读取字符串 jsonStr = sb.toString(); //转jsonOb
- 2019-03-23 22:02回答 1 已采纳 The easiest approach is to decode to map[string]interface{} and convert that to the desired struct
- 2018-05-23 05:24回答 2 已采纳 For javascript you probably don't want to use serialize and unserialize, but instead turn the resu
- 2022-04-14 23:23东河西的博客 这里写目录标题5. Flink流处理API5.1 Environment执行环境5.2 Source数据...基于key的分组转换keyBy()指定key的三种方式聚合（Aggregation）算子reduce归并三 多数据流转换ConnectUnion合流和Connect的区别？四 数据重
- 2021-12-22 15:39回答 2 已采纳 看样子没啥问题 包扫描那一块没有限制吧？
- 2021-02-28 17:07OOM先生的博客 FlinkKafkaConsumer Maven依赖： <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kafka_2.11</artifactId> <version>1...
- 2020-10-29 17:04Jasper·Deng的博客 两年开发经验的java开发应该哪些知识点？ 或者说，该如何学习java开发？ 下面我总结了一下自己的复习的思路，从JVM到分布式 （以下都是主要的知识点，已省略Mybatis、Hibernate等框架） 复习提纲 文章目录一、JVM1....
- 没有解决我的问题, 去提问
问题事件
系统已结题
6月28日
已采纳回答
6月20日
悬赏问题
- ¥15 在Windows中运行ollama出现运行缓慢的情况
- ¥15 下载ctorch报错，求解
- ¥15 如何入门学习c语言，单片机
- ¥15 idea 编辑语言的选择
- ¥15 Windows下部署Asmjit
- ¥15 请问双层规划模型的上下层目标函数不一致，是如何保证迭代收敛性的
- ¥15 微信小程序 前端页面内容搜索
- ¥15 cpu是如何判断当前指令已经执行完毕，然后去执行下条指令的
- ¥15 安装visual studio2022时visualstudiosetup启动不了，闪退。问题代号0x0和0x1389
- ¥30 java spring boot2.5.3版本websocket连不上