Kafka模板-使用通配符时不适用于参数

Question

我一直在建立Kafka制作服务。我用了？键值的通配符类型泛型，因此它可以是整数String等。

@Slf4j
public abstract class ProducerService<T> {

    protected KafkaClientConfigProperties properties;

    @Autowired
    protected KafkaTemplate<?, T> kafkaTemplate;

    public void send(T value, Iterable<Header> headers) {
        ProducerRecord<?, T> record = new ProducerRecord<>(properties.getTopic(), null, null, null, value, headers);
        this.kafkaTemplate.send(record);
    }

但是，在调用参数为ProducerRecord的send方法时，我遇到了错误

方法发送（生产记录）

我也试过了

ProducerRecord<String, T> record = new ProducerRecord<>(properties.getTopic(), null, null, null, value, headers);

并且有一个错误

生产记录

有人能帮我弄明白代码有什么问题吗？谢啦




Answer 1

这里有各种各样的东西可以改变/修复。首先，回答你提出的问题。出现问题的原因是，您正在创建的ProducerRecord包含一个null键变量。

因为这个类是泛型的，所以期望K作为键的类型，V作为值的类型，在那里传递null意味着K的类型不可能可以推断，这也是从你是的事实中得到增强的？作为键类型，这也是不正确的。

有各种方法可以缓解这种情况。

1. 如果您真的有兴趣发送头，那么您的类也应该接受键的类型（而不是通配符）。考虑以下示例：

public abstract class ProducerService<K, T> {

    @Autowired
    protected KafkaTemplate<K, T> template;

    public void send(T value, Iterable<Header> headers) {
    ProducerRecord<K, T> record = new ProducerRecord<>("topic", null, null, null, value, headers);
    template.send(record);
    }

}

public abstract class ProducerService<T> {

    @Autowired
    protected KafkaTemplate<String, T> template;

    public void send(T value, Iterable<Header> headers) {
    template.send("topic", value);
    }

}

从上面的两个示例可以看出，键入正确的键类型而不使用通配符对您来说应该很好。最后，还有一个建议是避免类泛型化。

对于特定的对象类型，不需要有多个生产者服务的实现。您可以简单地尝试和推广您的方法，以便能够处理任何类型的值。