Spring Kafka创建DefaultKafkaProducerFactory时类型推断错误求助

问题原因 #

构造DefaultKafkaProducerFactory时，由于使用DelegatingByTypeSerializer作为值序列化器，Java编译器无法自动推断工厂类的泛型类型参数，从而抛出cannot infer type arguments for DefaultKafkaProducerFactory<>错误。

解决方案 #

显式指定DefaultKafkaProducerFactory的泛型类型参数<String, Object>，替代菱形运算符<>, 帮助编译器明确类型信息。

修改后的代码 #

public ProducerFactory<String, Object> producerFactory() {
    return new DefaultKafkaProducerFactory<String, Object>(producerConfig(), 
        new StringSerializer(),
        new DelegatingByTypeSerializer(Map.of(
            byte[].class, new ByteArraySerializer(),
            Employee.class, new JsonSerializer<>()
        )));
}

@Bean
public KafkaTemplate<String, Object> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

补充说明 #

• 菱形运算符<> 的类型推断依赖上下文信息，当构造函数参数包含自定义序列化器这类复杂类型时，编译器推断逻辑可能失效，显式指定泛型是最直接的解决方式。
• 确保producerConfig()返回的配置中，没有重复指定key.serializer和value.serializer配置项，避免与构造函数传入的序列化器冲突。

内容的提问来源于stack exchange，提问作者Ajay Singh