java错误“KafkanConsumer类型不是泛型，不能用参数参数化”

Question

当我想实例化卡夫卡制作人时，我面临一个问题：

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);

the type kafkaconsumer is not generic it cannot be parameterized with arguments

我不理解这个错误，因为我知道我遵循的是官方的kafka javadoc，在该文件中，他们使用与我相同的依赖关系做完全相同的事情：

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

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

Answer 1

包含以下依赖项

<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.13</artifactId>
<version>2.5.1</version>
</dependency>

Answer 2

不要使用KafkaProducer或Producer作为其类名，因为您的类不是来自Kafka Jar

Answer 3

我也遇到了同样的问题。但过了一会儿，我意识到我给这个班起了个名字“KafkaProducer”。更改类名后，相同的代码被成功编译。 希望这对你有帮助。你能用类名和导入发布完整的类码吗

当我进一步研究原始的KafkaProducer类定义时，它是一个泛型类。有关更多信息，请查看：https://kafka.apache.org/10/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html