我正在尝试为一段将数据发送到Kafka主题的代码构建测试，我一直在阅读一个看起来非常简单的示例，但是当我尝试运行测试时，它抛出了这个错误：‘bootstrap.servers: spring.embedded.kafka.brokers中的无效url’。网址'spring.embedded.kafka.brokers‘我已经从文档中找到
浏览 45提问于2019-07-24得票数 3
回答已采纳
1回答
弹簧启动嵌入式卡夫卡无法连接
、、、、
我已经完成了测试，但是当我开始测试时，我只看到这个重复的无限的结果：
我在我的@EnableKafka类上有了@C
浏览 1提问于2019-04-03得票数 5
回答已采纳
1回答
我正面临着一个问题，我的Kafka ProducerConfig获取了一个无效的bootstrap.servers值，因为我的单元测试@PropertySource没有解析spring.embedded.kafka.brokers当我将我的生产者配置转储到日志中时，我得到了以下信息：batch.size = 10000
bootstrap.servers = [${spr
浏览 5提问于2019-03-06得票数 0
1回答
为了测试我们的spring引导应用程序在kafka集群还没有启动时是如何处理它的，我想在应用程序启动后的某个时候在junit测试中拆分一个嵌入式kafka集群。我怎么能接近这个？据我所知，spring测试的@EmbeddedKafka在创建SpringBootTest的应用程序上下文之前启动了
浏览 2提问于2021-09-14得票数 0
回答已采纳
1回答
如何在Spring Boot (2.2+)和Spring Kafka (2.4+)应用程序的@SpringBootTest测试中禁用@KafkaListener实例？目标是在特定测试中禁用Kafka侦听器，以便在不启动嵌入式Kafka代理的情况下运行此类测试。
浏览 39提问于2020-01-25得票数 3
回答已采纳
我正在创建一个spring引导应用程序，使用时态作为工作流引擎和kafka主题。因此，为了验证整个设置运行良好，我编写了使用spring引导测试、嵌入式kafka和时态测试的集成测试用例。但是我没有在内存工作流引擎中运行的任何选项或方法。
浏览 11提问于2021-06-14得票数 1
我在我的项目中使用了Kafka和Springboot，现在我有了外部Kafka集群和SpringBoot微服务项目。使用yml文件，我成功地创建了Kafka生产者和消费者，然后应用程序和kafka就可以很好地通信了。 activemq:
浏览 5提问于2019-01-18得票数 1
它定义了一个包含以下部分的拓扑：绿色中的数字显示了通过通过流绑定绑定的各个处理器定义的拓扑传递的消息数量，以下是各自的属性：@RunWith(SpringRunner.class) properties = "spring</em
浏览 1提问于2020-05-30得票数 2
回答已采纳
我们正在构建一个将使用Kafka Streams的应用程序。我们正在寻找示例示例，它向我们展示了如何为场景编写测试用例，其中我们从Kafka拓扑调用外部服务。我们使用TopologyTestDriver编写测试用例。由于这个外部调用，我们的测试用例没有执行。获取错误: POST请求时出现org.springframework.web.client.ResourceAccessException: I/O错误"：Co
浏览 0提问于2021-06-03得票数 2
我有一个基于Reactor的Spring Boot Kafka流处理应用程序，我正在为它编写集成测试。我使用的是Spring的@EmbeddedKafka代理。它工作得很好，我让它覆盖了在我的反应式处理器的消费者和发布者上配置的引导代理urls，但我还没有弄清楚的是在测试时如何处理我的处理器的模式注册表。我使用
浏览 38提问于2020-12-17得票数 0
我有一个非常简单的MessageHandler类，多亏了Spring Boot，它在运行时只需要以下几行代码和配置： @Component solace.jms.host=smf://aaaaa.xx.yy.com:8000完整的pom</groupId>
<arti
浏览 3提问于2018-09-27得票数 1
回答已采纳
我想使用EmbeddedKafkaBroker来测试涉及KafkaMessageDrivenChannelAdapter的流程， producer.flush();
...而主修班： public class Kafka) throws MessagingException {
浏览 6提问于2021-05-18得票数 0
回答已采纳
我正试图使用Spring-Kafka2.8.0和非阻塞重试功能为我的项目实现非阻塞重试。
我做了以下工作。autoCreateTopics属性是假的！，它使用kafka作为嵌入式容器。测试模拟db连接问题-测试中的代码必须抛出在使用者中声明为可还原的AerospikeException.Timeout。这个测试正在成功地通过，但据我所知，autoCreateTop
浏览 17提问于2021-12-08得票数 0
回答已采纳
3回答
我正在使用一个Java应用程序来启动消费者阅读Kafka主题。每次我需要启动使用者应用程序时，我都必须使用cmd中的命令启动和Kafka服务器。是否有可能用小型Java程序启动/阻止它们？谢谢。
浏览 1提问于2017-06-17得票数 3
回答已采纳
我正在使用一个Spring Boot应用程序，该应用程序是使用Apache Camel spring-xml routes编写的。很少有基于java的应用程序逻辑，它几乎完全是用xml编写的，并且基于各种camel路由。
这些路由配置为使用KAFKA_URL and KAFKA_PORT等属性通过属性文件连接到不同的环境和系统。amp;delay={{env:FTP_POLL_DELAY:{{FTP_POLL_DELAY}}}}&am
浏览 23提问于2019-10-31得票数 0
回答已采纳
1回答
我正在编写一个使用嵌入式kafka的junit测试用例。我们有一个管道，其中生产者>主题>消费者>做工作()>生产。我正在使用第三方模式注册中心(通过给出一个假url来模拟这个注册中心)，而特定的serdes绑定到它的.After上，在kafka用户组讨论这个问题时，这样做的方法是使用模拟注册表手动序列化数据，并将byte[]本身传递到生产者而不是avro记录中。在这种情况下
浏览 1提问于2018-11-06得票数 2
回答已采纳
1回答
我有一个简单的Spring应用程序，它从Kafka主题读取并将消息保存到一些缓存中。我想添加一个集成测试，它将启动我的原始应用程序，生成一些来自嵌入式Kafka的消息，然后断言缓存内容。我在挣扎于“启动我的原始应用程序”部分。如何在Spring集成测试中做到这一点？OriginalApplicationIntegrationTest {
浏览 1提问于2020-01-08得票数 0
回答已采纳
我在一个应用程序中使用spring-boot-starter-parent version 1.5.0.RELEASE、spring-kafka version 1.0.0.RELEASE和spring-kafka-testversion 1.0.0.RELEASE，该应用程序使用来自Kakfa 0.9集群的消息。我为我的使用者进行了一个单元测试，它使用了KafkaEmbedded，但是由于代理端口是随机获取的，所以它失败了。我是否可
浏览 2提问于2019-05-20得票数 2
Spring Boot: 2.0.3版本 org.apache.kafka.kafka-streams: 1.0.0 Org.apache.kafka.kafka-客户端: 1.0.0 org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE 我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https://b
浏览 92提问于2019-04-30得票数 0
回答已采纳
1回答
另一方面，当我发送无效的json时，我希望触发错误日志记录方法。这在一些测试用例中有效，而在另一个测试用例中不起作用。我的应用程序反序列化json，即使它是无效的，并且触发包含逻辑的方法，而不是错误日志记录方法。
我无法解决为什么框架反序列化一些非结构化的json输入的问题。=${spring.embedded.kafka.brokers}&qu
浏览 12提问于2021-06-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
