1 背景

使用spring boot KafkaTemplate 作为生产者消费消息

key 为 string

value byte[]数组

2 发生问题代码

        ProducerRecord<String,byte[]> record = new ProducerRecord<>(adcode,bytes);ListenableFuture future = kafkaTemplate.send(record);// 添加回调，异步等待响应future.addCallback(new ListenableFutureCallback<SendResult>() {@Overridepublic void onFailure(Throwable throwable) {System.out.println("发送失败: " + throwable.getMessage());}@Overridepublic void onSuccess(SendResult result) {System.out.println("发送成功：" +result.getRecordMetadata().topic() + "\t"+ result.getRecordMetadata().partition() + "\t"+ result.getRecordMetadata().offset());}});

3 问题定位

自己的配置文件写错了

    producer:key-deserializer: org.apache.kafka.common.serialization.StringSerializervalue-deserializer: org.apache.kafka.common.serialization.ByteArraySerializer

应该改为

    producer:key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.ByteArraySerializer

Can‘t convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer spec相关推荐

kafka 异步发送阻塞_Kafka学习一
一.github下载kafka的源码可以看到kafka的源码开源社区是非常活跃的. 二.搭建kafka环境构建kafka环境,首先需要安装Scala和gradle,再安装的scala插件需要和你的 ...
kafka使用_Kafka生产者的使用和原理
本文将学习Kafka生产者的使用和原理,文中使用的kafka-clients版本号为2.6.0.下面进入正文,先通过一个示例看下如何使用生产者API发送消息. public class Produce ...
快速了解 Kafka 生产者的使用和原理
作者 | 草捏子整理 | 杨碧玉出品 | 草捏子(ID:chaycao) 头图 | CSDN 下载自视觉中国本文将学习 Kafka 生产者的使用和原理,文中使用的 kafka-clients ...
大数据日志分析系统-logstash
logstash简介 Logstash 是一个开源的数据收集引擎,它具有备实时数据传输能力.它可以统一过滤来自不同源的数据,并按照开发者的制定的规范输出到目的地. logstash-2.2.2的配置: ...
kafka 命令、API
日萌社人工智能AI:Keras PyTorch MXNet TensorFlow PaddlePaddle 深度学习实战(不定时更新) 大数据组件使用总文章 kafka 生产/消费API.offs ...
【MQ】Kafka笔记
笔记来源:尚硅谷视频笔记2.0版+2.1版黑马视频:Kafka深入探秘者来了 kafka笔记地址:https://blog.csdn.net/hancoder/article/details/107 ...
4.2.10 Kafka源码剖析, 阅读环境搭建, broker启动流程, topic创建流程, Producer生产者流程, Consumer消费者流程,
目录 4.1 Kafka源码剖析之源码阅读环境搭建 4.1.1 安装配置Gradle 4.1.2 Scala的安装和配置 4.1.3 Idea配置 4.1.4 源码操作 4.2 Kafka源码剖析之B ...
Spark心跳存活-延迟处理-异常日志告警
Spark心跳存活-延迟处理-异常日志告警 1.目录大纲 spark异常日志告警 spark存活心跳告警 spark批次处理延迟告警 2.任务背景 2.1问题背景生成中针对spark steam ...
Spring Boot 3.0.0-M1 Reference Documentation(Spring Boot中文参考文档) 9-16
9. 数据 Spring Boot与多个数据技术集成,包括SQL和NoSQL. 9.1. SQL数据库 Spring Framework提供扩展支持用于与SQL数据工作,从使用JdbcTemplate ...

Can‘t convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer spec

1 背景

2 发生问题代码

3 问题定位

Can‘t convert value of class [B to class org.apache.kafka.common.serialization.StringSerializer spec相关推荐

最新文章

热门文章