SpringBoot, Kafka: java.lang.NoSuchMethodError: org.apache.kafka.clients.producer.Producer.close(Ljava/time/Duration;)V ⇐ Java

[Anonymous]

Ich verwende Spring Boot v2.2.4 und Apache Kafka in meinem Projekt.
Unten ist meine pom.xml-Datei:

Code: Select all

org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-webflux


org.springframework.boot
spring-boot-starter-test
test


org.springframework.boot
spring-boot-starter-data-jpa


com.h2database
h2
1.4.200


org.springframework.boot
spring-boot-devtools
runtime
true



org.springframework.boot
spring-boot-configuration-processor
true


com.github.docker-java
docker-java
3.1.5


org.springframework.kafka
spring-kafka


org.apache.kafka
kafka_2.11
0.11.0.0



org.apache.kafka
kafka-clients
0.11.0.0



org.scala-lang
scala-library
2.12.3



org.slf4j
slf4j-api
1.7.25


org.slf4j
slf4j-log4j12
1.7.25
test


log4j
log4j
1.2.17

Unten ist der Code, den ich als Teil von Kafka habe

Code: Select all

@Configuration
public class KafkaConfig {

@Bean
public ProducerFactory producerFactoryServingDetail(){
Map config = new HashMap();
config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"127.0.0.1:9092");
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
return new DefaultKafkaProducerFactory(config);
}

@Bean
public ProducerFactory  producerFactory(){
Map config = new HashMap();
config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"127.0.0.1:9092");
config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
return new DefaultKafkaProducerFactory(config);
}

@Bean
public KafkaTemplate kafkaTemplateItem(){
return new KafkaTemplate(producerFactoryServingDetail());
}

@Bean
public KafkaTemplate kafkaTemplate(){
return new KafkaTemplate(producerFactory());
}
}

Wenn eine JSON-Nachricht an die Kafka-Warteschlange gesendet wird, erhalte ich die folgende Fehlermeldung

Code: Select all

java.lang.NoSuchMethodError: org.apache.kafka.clients.producer.Producer.close(Ljava/time/Duration;)V
at org.springframework.kafka.core.KafkaTemplate.closeProducer(KafkaTemplate.java:382) ~[spring-kafka-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.springframework.kafka.core.KafkaTemplate.lambda$buildCallback$4(KafkaTemplate.java:433) ~[spring-kafka-2.3.5.RELEASE.jar:2.3.5.RELEASE]
at org.apache.kafka.clients.producer.internals.ProducerBatch.completeFutureAndFireCallbacks(ProducerBatch.java:198) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.ProducerBatch.done(ProducerBatch.java:185) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:570) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:550) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:474) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:75) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:660) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:101) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:454) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:446) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:224) ~[kafka-clients-0.11.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162) ~[kafka-clients-0.11.0.0.jar:na]
at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_201]

Die JSON-Nachricht erreicht jedoch die Warteschlange. Ich möchte verstehen, warum ich den obigen Fehler erhalte.