我有一个带有@KafkaListener方法的spring组件： @Slf4jpublic class ResponseHandler {
this.responseMessageService= responseMessageService; responseMessageSer
浏览 8提问于2019-04-15得票数 0
我有一个应用程序，它使用2.10.0版本中的SpringBoot 2.10.0 version和kafka。这个应用程序有一个简单的生产者和消费者:发送者使用KafkaTemplate，消费者使用KafkaListener。我试图实现的目标是即使KafkaServer没有运行，也能够启动SpringBoot应用程序。目前，如果没有正在运行的KafkaBroker，应用程序将无法启动，并显示以下错误消息： org.springframe
浏览 216提问于2019-01-25得票数 2
我在我的应用程序中使用SpringBoot依赖项来使用Kafka。在我的Kafka实例启动并运行之前，一切都很好，但是问题是我的unit&integration测试，它们在我的本地运行，但在我的部署管道中运行得很好(这很明显，因为应用程序在运行测试时试图连接构建管道中的只有在我有一个带有@KafkaListener注释的方法之前，才会发生这种情况。，测试用例就会正常工作。是
浏览 2提问于2019-05-16得票数 1
1回答
注释中使用主题值的值@KafkaListener(topics={"#{'${topics}'.split(',')}"})我如何循环这个列表我读到用这种方式调用一个方法是可能的：所以，我写了这个方法：
public String[]
浏览 0提问于2020-10-16得票数 0
我试图在一个消费者组中创建多个消费者，以便进行并行处理，因为我们有大量的消息流入。我使用的是spring boot和KafkTemplate。如何在spring boot应用程序的单个实例中创建属于单个消费者组的多个消费者？使用@KafkaListener注释多个方法会创建多个消费者吗？
浏览 121提问于2020-07-01得票数 2
回答已采纳
最重要的是，“汽车”前缀背后的原因是什么？用@Configuration而不是@AutoConfiguration注解的类不那么自动或什么的？
浏览 19提问于2022-10-18得票数 1
回答已采纳
我有一个简单的Spring Boot应用程序，它从Kafka读取和写入Kafka。我使用EmbeddedKafka编写了一个SpringBootTest来测试所有这些。主要问题是:有时测试会失败，因为测试过早地发送了Kafka消息。这样，在Spring应用程序(或者更准确地说，是它的KafkaListener )准备就绪之前，消息就已经写入了Kafka。由于侦听器从latest偏移量读取(我不想更改测试的任何配置-bootstrap.servers除外
浏览 0提问于2019-04-11得票数 8
我想加快对API的自动验收测试，我发现最好的方法是创建一个API端点，允许在每次测试运行后自动接受测试来擦除我的数据库。与其他技术相比，这给了我显着的性能改进。为了避免发送delete端点，我将带有delete端点的@Controller包含到自己的maven模块中，然后尝试使用maven的“test”作用域(然后在不起作用时“提供”范围)将maven模块包含在API中。不幸的是，如果我使用'test‘或'provided’范围，似
浏览 0提问于2016-08-04得票数 0
回答已采纳
我一直在使用@KafkaListener作为一类Kafka事件消费者，它必须具有唯一的ids，并且每个事件使用者都必须有一个具有非常特殊名称的单独组。在SpringBoot2.2中，我为此使用了一个分离的BeanPostProcessor，并在初始化之前生成了需要的字段，并用需要的实例替换了使用者的KafkaListener注释，但是在SpringBoot2.5.0中，这个特性不再可用，因为合成新的基于KafkaListeners的新
浏览 10提问于2021-05-31得票数 0
3回答
我有一个JUnit测试，它在测试之后启动一个spring-boot应用程序(在我的例子中，主类是SpringTestDemoApp)：@RunWith(SpringJUnit4ClassRunner.class@Test // Test http://localhost:8080/ (with Selenium)}
使用</em
浏览 0提问于2017-04-07得票数 7
回答已采纳
我有一个简单的Spring Boot应用程序，其中有多个用@KafkaListener注释的方法。我希望他们中的一些人使用自动确认，而另一些人使用手动确认。有没有可能在不手动设置容器工厂的情况下，使用Spring Boot配置来实现这一点？根据的说法，使用@KafkaListener需要如下代码
@KafkaListener(id = "cat", topics = "
浏览 0提问于2021-01-17得票数 0
我试图在不使用@KafkaListener注释的情况下为某个主题创建一个Kafka消费者。我之所以想这样做，是因为我试图在不使用spring的情况下，基于application.properties动态创建侦听器。我认为最好的方法是手动创建一个KafkaListenerContainerFactory，请提供一个示例说明如何在它自己的类中这样做。
浏览 2提问于2019-07-19得票数 3
回答已采纳
我正在使用@KafkaListener(topics = "${topic}")来消费来自spring-boot应用程序中某个主题的消息，并且我需要定期运行该应用程序。要实现这一点，一种方法是使用fetch.max.wait.ms每6小时进行一次批处理，但对于这种配置来说，6小时似乎太多了。
因此，我正在寻找一种方法，在处理后关闭应用程序，并每6小时重新启动一次。其他方式类似于下面，但它不能保证<
浏览 16提问于2020-05-06得票数 0
回答已采纳
1回答
“没有弹簧引导”是什么意思，因为这个例子肯定会使用spring引导。我好困惑..。编辑
被设计用于Spring应用程序</em
浏览 9提问于2022-10-03得票数 1
我想用嵌入式kafka来测试我的处理器。这有可能吗？当我使用Kafka & ZK在本地运行应用程序时，它可以完美地工作--我的示例侦听器接收与处理器相同的消息(太棒了，两者都侦听相同的主题)，但是当我使用嵌入式kafka测试它时，只有带有@KafkaListener注释的方法收到消息，而处理器什么也得不到。
浏览 0提问于2018-05-08得票数 0
我有一个使用RestTemplate的简单服务类。我正在使用@RestClientTest测试它，并期望仅初始化所需的服务beanclass DemoApplication { .body("hello world"))
}
我希望在测试中
浏览 1提问于2020-03-09得票数 0
我有一个spring引导应用程序，它通过Maven的mvn spring-boot:run命令运行得很好。然而，当我尝试通过集成开发环境运行它时，它失败了，因为它不能@Autowire数据源。这个代码库的原始作者有主类，它启动应用程序，接受数据源的构造函数参数，这是一种我不熟悉的方法，因为我习惯于只通过application.properties文件完成这项工作，并让Spring Boot连接它自己的下面是一些在主应用程序起始类中被覆盖的其他方法，
浏览 20提问于2017-08-17得票数 1
回答已采纳
我使用spring 2.0.3创建了一个rest应用程序。从另一个maven模块(在不同的多模块pom中)，我有一个集成测试，测试发送到正在运行的rest应用程序的数据是否被处理。是否有可能以编程方式运行这个弹簧引导应用程序？我不能使用简单@SpringBootTest-注释，因为spring-boot应用程序不在同一个maven多模块中。
浏览 1提问于2018-06-17得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
