Ошибка создания bean-компонента с именем «kafkaListenerContainerFactory». ⇐ JAVA

[Anonymous]

Я новичок в Kafka, Springboot и пытаюсь интегрировать поиск Kafka и Elastic в свое приложение Springboot.

Когда я пытаюсь запустить приложение Springboot, я вижу ошибку ниже. :

Код: Выделить всё

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaListenerContainerFactory' defined in class path resource [org/springframework/boot/autoconfigure/kafka/KafkaAnnotationDrivenConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory]: Factory method 'kafkaListenerContainerFactory' threw exception; nested exception is java.lang.NoSuchMethodError:org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory.getContainerProperties()Lorg/springframework/kafka/listener/config/ContainerProperties;

Мой pom.xml

Код: Выделить всё

 
org.springframework.kafka
spring-kafka
2.2.3.RELEASE


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


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


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


net.java.dev.jna
jna
4.1.0

Application.yml

Код: Выделить всё

  security:
enabled: true

spring:
resources:
chain:
enabled: true

kafka:
consumer:
bootstrap-servers: localhost:9092
group-id: group-id
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
producer:
bootstrap-servers: localhost:9092
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringDeserializer

Класс производителя

Код: Выделить всё

@Service
public class Producer {
private static final Logger logger = LoggerFactory.getLogger(Producer.class);
private static  final  String topic = "users";

@Autowired
private KafkaTemplate kafkaTemplate;

public void sendMessage(History t){
logger.info("Inside send message to topic");
this.kafkaTemplate.send(topic,"HelloWorld");
}

}

Consumer.java

Код: Выделить всё

package com.springboot.kafka;

import com.springboot.model.History;
import com.springboot.repository.HistoryRepository;
import org.apache.kafka.common.protocol.types.Field;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class Consumer  {
private static final Logger logger = LoggerFactory.getLogger(Consumer.class);
private static  final  String topic = "users";

@KafkaListener(topics = topic,groupId = "group-id")
public void consume (String t){
logger.info("Message read as " + t);

}
}

Application.properties:

Код: Выделить всё

logging.level.sql=info
logging.file = /var/tmp/SpringBootAppLog.log
spring.datasource.driver=org.postgresql.Driver
spring.datasource.url=jdbc:postgresql://localhost:5432/test
spring.datasource.username=postgres
spring.datasource.password=postgres

spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.PostgreSQLDialect
spring.jpa.properties.hibernate.show_sql=true
spring.jpa.hibernate.ddl-auto=update
spring.data.elasticsearch.cluster-name=my-application
spring.data.elasticsearch.cluster-nodes=localhost:9200

Любая идея о том, чего мне не хватает. Любые предложения будут высоко оценены.

Подробнее здесь: https://stackoverflow.com/questions/582 ... nerfactory