Kafka Producer序列化问题

报错如下

Caused by: java.lang.ClassCastException: [B cannot be cast to java.lang.String

关键代码：

Properties properties = new Properties();
properties.put("metadata.broker.list", "***");
properties.put("serializer.class","kafka.serializer.StringEncoder");
private Producer<String, byte[]> producer=
        new Producer<String, byte[]>(new kafka.producer.ProducerConfig(properties));
producer.send(new KeyedMessage<String, byte[]>("my_topic",
         SchemaUtils.getSchemaByte(record, schema)));

问题原因： kafka producer 序列化有两个配置 serializer.class和key.serializer.class 前者是value，后者是key 且有支持两种配置参数 kafka.serializer.DefaultEncoder 默认的序列化方式为byte数组 kafka.serializer.StringEncoder String序列化

在这里插入图片描述如上代码只配置了serializer.class，没有配置key的序列化方式，所以key默认和value的序列化方式一样是String，但是我们代码发送的是avro格式的byte[]数组，所以报上面的异常解决加粗样式办法：

properties.put("key.serializer.class","kafka.serializer.StringEncoder");

指定key的序列化方式为String，value的用default方式

Kafka Producer序列化问题

CATALOG

FEATURED TAGS

FRIENDS