返回使用 String 作为键的异常,spring,apache-kafka,spring-kafka,spring-kafka-test"/>
时间戳

首页 > 解决方案 > 使用 KafkaTemplate 发送返回使用 String 作为键的异常

spring - 使用 KafkaTemplate 发送返回使用 String 作为键的异常

问题描述

当使用 Integer 作为键时，这不是问题，kafka 应该能够将字符串作为键来处理。

ProducerFactory<String, String> pf =
                new DefaultKafkaProducerFactory<String, String>(senderProps);
KafkaTemplate<String, String> template = new KafkaTemplate<>(pf);
ProducerRecord<String,String> pr = new ProducerRecord<>("my-topic", "key1","test");
        template.send(pr);`

它抛出以下异常：

Org.apache.kafka.common.errors.SerializationException：无法将类 java.lang.String 的键转换为 key.serializer 中指定的类 org.apache.kafka.common.serialization.IntegerSerializer

原因：java.lang.ClassCastException：java.lang.String 无法在 org.apache.kafka.common.serialization.IntegerSerializer.serialize(IntegerSerializer.java:21) 的 org.apache.kafka 中转换为 java.lang.Integer .common.serialization.ExtendedSerializer$Wrapper.serialize(ExtendedSerializer.java:65) at org.apache.kafka.common.serialization.ExtendedSerializer$Wrapper.serialize(ExtendedSerializer.java:55) at org.apache.kafka.clients.producer .KafkaProducer.doSend(KafkaProducer.java:799) at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:784) at org.springframework.kafka.core.DefaultKafkaProducerFactory$CloseSafeProducer.send(DefaultKafkaProducerFactory.java :285) 在 org.springframework.kafka 的 org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:357)。core.KafkaTemplate.send(KafkaTemplate.java:206)

标签： springapache-kafkaspring-kafkaspring-kafka-test

解决方案

似乎，您的密钥序列化程序在 ProducerConfig 中设置为整数。您需要将其设置KEY_SERIALIZER_CLASS_CONFIG为 String ：

@Bean
    public Map<String, Object> producerConfigs() {
        Map<String, Object> props = new HashMap<>();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return props;
    }

推荐阅读