2017-12-07 6 views
1

Während einer Feder Boot-Anwendung mit Feder-Integration-kafka Bibliothek läuft, ist mir die folgende Fehlermeldung erhalten:Frühling Integration Kafka ClassNotFoundException: KafkaHeaderMapper

Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.support.KafkaHeaderMapper

Die Ausnahme wird in der ersten Zeile in dem Körper der geworfen folgende Methode:

@ServiceActivator(inputChannel = "producerChannel") 
public MessageHandler kafkaMessageHandler() { 
    KafkaProducerMessageHandler<String, String> handler = 
     new KafkaProducerMessageHandler<>(kafkaTemplate()); 
    handler.setMessageKeyExpression(new LiteralExpression("kafka-integration")); 

    return handler; 
} 

Mein pom.xml ist:

<parent> 
    <groupId>org.springframework.boot</groupId> 
    <artifactId>spring-boot-starter-parent</artifactId> 
    <version>1.5.9.RELEASE</version> 
    <relativePath /> <!-- lookup parent from repository --> 
</parent> 

<properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> 
    <java.version>1.8</java.version> 
</properties> 

<dependencies> 
    <dependency> 
     <groupId>org.apache.kafka</groupId> 
     <artifactId>kafka-clients</artifactId> 
     <version>1.0.0</version> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.boot</groupId> 
     <artifactId>spring-boot-starter-integration</artifactId> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.integration</groupId> 
     <artifactId>spring-integration-kafka</artifactId> 
     <version>2.3.0.RELEASE</version> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.kafka</groupId> 
     <artifactId>spring-kafka</artifactId> 
    </dependency> 
    <dependency> 
     <groupId>org.projectlombok</groupId> 
     <artifactId>lombok</artifactId> 
     <optional>true</optional> 
    </dependency> 
    <dependency> 
     <groupId>org.springframework.boot</groupId> 
     <artifactId>spring-boot-starter-test</artifactId> 
     <scope>test</scope> 
    </dependency> 
</dependencies> 
<build> 
    <plugins> 
     <plugin> 
      <groupId>org.springframework.boot</groupId> 
      <artifactId>spring-boot-maven-plugin</artifactId> 
     </plugin> 
    </plugins> 
</build> 

Was Vermisse ich?

Antwort