启动spring boot kafka项目时获取错误。spring boot :2.1.2版本Spring kafka版本: 2.2.5.RELEASE 无法为ackMode MANUAL_IMMEDIATE配置使用者以进行自动提交 消费者配置 @Beanprops.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class
浏览 30提问于2019-04-03得票数 2
回答已采纳
我看到一些人将@EnableKafka添加到他们的spring boot应用程序中，我想知道为什么。我有一个可以正常工作的spring boot kafka生产者和消费者，我没有使用@EnableKafka。那么，为什么人们需要明确地添加它呢？ 谢谢。
浏览 181提问于2020-04-17得票数 16
回答已采纳
为了通过Junit理解Springboot Kafka单元测试，我正在尝试从github中编写已经实现的示例。我是测试新手。当我尝试作为Junit运行它时，我使用了这个代码Github ，然后它给出了下面提到的错误： 2021-06-16 18:14:15.907 INFO 9864 --- [ main] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1] Closing the Kafka producer--- [
浏览 100提问于2021-06-16得票数 0
回答已采纳
我有一个gradle项目，它被用作其他项目中的库。库项目指定了一个依赖项： compile('org.apache.kafka:kafka-clients') { }
} 然而，当构建另一个使用这个库的项目时，版本被降级到'2.3.1‘。我发现这是因为该项目还使用了
浏览 112提问于2021-08-03得票数 0
我的问题是关于Spring和Spring的兼容性。我正在使用以下版本：
建议所有拥有代理>= 0.10.x.x (以及所有spring 1.5.x用户)的用户使用Spring-KafkaVers
浏览 2提问于2018-11-29得票数 1
回答已采纳
1回答
在Spring Boot应用程序中，我希望使用Spring Integration从Kafka队列中读取数据。Spring Boot应用程序的注释如下：所以不应该有Kafka bean(KafkaMessageListenerContainer.java:736) [spring-kafka-1.1.7.RE
浏览 10提问于2018-02-21得票数 1
1回答
我已经将我的kafka从版本0.10.2.0更新到versión 2.1.0，现在kafka不能消费消息。我使用的是spring boot，下面是我的配置： configProperties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaServers);
configProperties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.se
浏览 30提问于2019-06-23得票数 0
我正在尝试做一个小的微服务项目来接触卡夫卡。要启动kafka，我正在使用docker compose： kafka-server:ports:- 9092:9092 <groupId>org.springframework.boot</groupId>
<artif
浏览 39提问于2020-04-28得票数 0
回答已采纳
得到：原因: java.lang.ClassNotFoundException: com.codahale.metrics.Reservoir<kafka.version>2.8.1</kafka.version>sprin
浏览 17提问于2022-07-25得票数 0
回答已采纳
在微服务架构中使用Kafka作为消息传递系统，我想知道首选的是Spring Kafka还是Spring Integration Kafka，为什么？另外，我们根据什么因素来决定选择哪一个？
浏览 75提问于2020-04-13得票数 2
我有一个spring boot项目，它有一个依赖项(另一个spring-boot项目)，实现如下所示。配置并执行new KafkaProducer<>(producerProperties) 项目和问题的上下文。上面的代码来自一个实用程序，它也没有什么其他东西是spring boot项目中唯一感兴趣的东西，而不是kafka实现。但是，当我启动spring</em
浏览 204提问于2021-08-02得票数 0
1回答
我们有一个spring引导服务，它总是在启动时得到这个错误： at org.springframework.kafka.core.KafkaAdmin.addTopicsIfNeeded(KafkaAdmin.j
浏览 10提问于2022-03-03得票数 1
回答已采纳
您好，我正在使用Spring Boot的@kafkaListener。我正在消费一批消息。我正在尝试使用Acknowledgment中的nack()方法，但看起来Spring Boot 2.1.8不支持nack()方法。Spring Boot 2.1.8中有没有像nack()这样的特性 我想抛出一个失败记录的异常，并在下一个poll()中重播剩余的记录。我如何在Spring Boot 2.1.8中实现这一点。
浏览 447提问于2021-09-21得票数 0
1回答
我正在学习Spring事件驱动开发教程。此时，目标是实现事件驱动实现的不可知论/可移植实现。有了RabbitMQ，一切都很好，但是在卡夫卡，一切都不起作用。问题似乎是，Kafka生产者在主题中添加了项目名称作为前缀，而消费者不知道这个前缀。: kafka
浏览 4提问于2021-01-18得票数 0
回答已采纳
3回答
目标是在数组中有一个依赖项列表，这样每个列表都可以在子项目中单独分配。:spring-boot-starter-data-redis',
'org.springframework.boot:spring-boot-starter-web','org.mybatis.spring.boot:mybatis-spring-boot-starter:2.0.1
浏览 15提问于2019-05-08得票数 0
回答已采纳
我使用的是spring-boot-parent 1.5.10.RELEASE。<dependency> <artifactId>spring-kafka</artifactId</groupId>
<artifactId>spring-k
浏览 0提问于2018-02-16得票数 6
回答已采纳
我想在Spring中使用Kafka客户端。我添加了maven依赖项。 <spring.boot.version>2.2.1.RELEASE</spring.boot.version>
<spring.version>5.2.1.RE
浏览 12提问于2019-12-03得票数 0
回答已采纳
1回答
如何在Spring Boot (2.2+)和Spring Kafka (2.4+)应用程序的@SpringBootTest测试中禁用@KafkaListener实例？目标是在特定测试中禁用Kafka侦听器，以便在不启动嵌入式Kafka代理的情况下运行此类测试。
浏览 39提问于2020-01-25得票数 3
回答已采纳
我有一个Spring项目运行SpringBoot2.0.2。在单元测试中，我试图启动一个KafkaEmbedded服务器。我知道这个错误。<parent> <artifactId>spring-boot-starter-parent</</groupId>
<artif
浏览 2提问于2018-06-06得票数 3
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
