SaleResponseFactory();}Caused by: org.apache.kafka.common.KafkaException: class org.engine.plugin.transactions.factory.SaleResponseFactory is not an instance of org.apache.kafka</e
在我的简单应用程序中,我试图实例化一个KafkaConsumer,我的代码几乎是的副本(“自动偏移提交”):public class MyKafkaConsumer {
at org.apache.kafka.clients.consumer.KafkaConsumer.Caused by: org.apache.kafka.common.Ka
我有这个kafka配置类public class KafkaConfiguration { privatereturn new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(this.producerConfigs()));}
我希望使用spring引导自动配置,以便获得上面的配置类,所以我在appliction