错误“kafkaconsumer 类型不是通用的，不能用参数参数化”

Question

当我想实例化 KafkaProducer 时，我遇到了一个问题：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(props);

kafkaconsumer 类型不是通用的，它不能用参数参数化

我不明白这个错误，因为我知道我正在关注官方的 kafka javadoc，其中他们做的事情与我的依赖完全相同：

https://kafka.apache.org/11/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html

谁能给我解释一下这个笑话？

Answer 1

我也遇到同样的问题。但过了一会儿我意识到我给了班级名称 'KafkaProducer' 。更改我的类名后，相同的代码编译成功。希望这对你有帮助。您可以发布带有类名和导入的完整类代码吗？

当我进一步查看原始 KafkaProducer 类定义时，它是一个通用类。有关更多信息，您可以查看：https : //kafka.apache.org/10/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html