为此，我使用了Spring的EmbeddedKafka。PLAINTEXT://localhost:9091", "port=9091"}) @Autowired private EmbeddedKafkaBroker下面是我得到的错误： Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No qualifying bea
浏览 30提问于2019-08-23得票数 1
回答已采纳
我正在写一个使用Kafka Streams，Spring-Kafka和Spring Boot的流应用程序。在使用Spring-Kafka时，我找不到任何信息来正确测试Kafka Streams DSL所做的流处理。文档提到了EmbeddedKafkaBroker，但似乎没有关于如何处理测试的信息，例如状态存储。 只是提供一些简单的例子来说明我想要测试的内容。我注册了以下bean (其中Item是avro生成的)： @Bean
publi
浏览 25提问于2019-08-31得票数 3
一个在Spring-boot 2.2.6.RELEASE和Spring-kafka 2.4.1.RELEASE上运行我们的测试套件的项目在升级到Spring-boot 2.3.1.RELEASE和Spring-kafka它似乎找不到kafka.utils.TestUtils。
我已经尝试将spring-kafka版本留空，以便允许spring-boot提取一个兼容的版本，但错误仍然存在。build.gradle文件：
浏览 0提问于2020-07-15得票数 0
我的项目有以下依赖关系：compile "org.springframework.kafka:spring-kafka:2.4.4.RELEASE"public class KafkaServer {
public voi
浏览 0提问于2020-03-25得票数 2
我用嵌入的kafka (Spring test )创建了一组测试(JUnit 5)，当我有时(并不总是)运行它们时，在一个或多个测试中一次性运行“主题'some_name‘已经存在的”。DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)public class RemovalKafkaTestIT {
private EmbeddedKafkaBrokerembeddedKafkaBroker = new <
浏览 0提问于2020-01-23得票数 1
回答已采纳
<init>(EmbeddedKafkaBroker.java:660) ~[spring-kafka-test-2.5.2.RELEASE.jar:2.5.2.RELEASE]
at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:287) ~[spring-kafka-test-2.5.2.RELEASE.jar:2.5.2.RELEASE]
浏览 0提问于2020-06-22得票数 0
回答已采纳
当我们用以下方法初始化EmbeddedKafkaBroker时：<dependency> <artifactId>spring-<e
浏览 0提问于2019-06-02得票数 2
1回答
我希望在一个只允许上述应用程序运行的环境中部署一个spring引导应用程序。我的应用程序将是卡夫卡的生产者和消费者。是否有一种方法可以在启动时运行内存实例，用于测试以外的目的？
浏览 9提问于2020-09-09得票数 2
在advice here之后，我尝试使用嵌入式Kafka来测试我的Spring Boot Streams应用程序。只需创建给定的配置 @Configurationpublic class StreamsTestConfiguration {
private String brokerAd
浏览 135提问于2019-05-06得票数 3
回答已采纳
2回答
多重卡夫卡消费者没有收到信息
、、、、
embeddedKafkaBroker;
* bean for the embeddedKafkaBroker* */ @Qualifier("embeddedKafkaBroker")
publicspring.kafka.producer.key-serializer=org.apache.kafka
浏览 3提问于2022-08-13得票数 0
回答已采纳
我尝试使用嵌入式kafka进行测试，我使用spring boot和junit5，如下所示 @SpringBootTestpublic class MyTest {EmbeddedKafkaBroker embeddedKafka = new EmbeddedKafkaBrokerresolvable bootstrap urls given in bootstrap
浏览 22提问于2020-01-30得票数 2
下面是我的应用程序的一个示例(源代码：)：class Application { fun embeddedKafkaBroker(): EmbeddedKafkaBroker = EmbeddedKafkaBroker(1).kafkaPorts(9092) <artifactId>spri
浏览 5提问于2021-12-13得票数 0
2回答
我正在尝试使用spring-boot和spring进行集成测试。我能够向spring嵌入式Kafka服务器生成消息，但是服务类中的侦听器尝试使用记录和@EnableKafkapublic EmbeddedKafkaBroker embeddedKafk
浏览 2提问于2019-02-19得票数 1
回答已采纳
1回答
我有一个spring引导应用程序，它让使用者从一个集群中的主题消费，然后在不同的集群中生成另一个主题。现在我正在尝试用spring编写集成测试用例，但是有一个KafkaTemplate could not be registered.A bean with that name has already been defined in class path resource问题@Service误差
The bean 'kaf
浏览 0提问于2019-02-18得票数 1
回答已采纳
1回答
GenTraversableOnce at org.springframework.kafka.test.EmbeddedKafkaBroker<init>(EmbeddedKafkaBroker.java:738)
at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet("org.apache.kafka:
浏览 1提问于2020-09-09得票数 1
回答已采纳
1回答
配置可以如下所示： application: cloud: schema-registry-clientorg.apache.kafka.common.serialization.Serdes$IntegerSerde registry:
url: ${spring.cloud.stream.schema-registry-client
浏览 0提问于2019-07-31得票数 1
回答已采纳
当试图加载Spring引导应用程序时，嵌入的kafka对象不是自动加载的。这是用于非测试流的。boot Application"); protected EmbeddedKafkaBroker&#x
浏览 3提问于2020-01-16得票数 0
在获得下一个错误时，我无法运行spring应用程序，“考虑在您的配置中定义'exampleService(exampleService is interface)‘类型的bean”。
浏览 1提问于2022-07-20得票数 0
我有一个小的库，它提供了一个围绕EmbeddedKafkaBroker的JUnit 5扩展，它试图通过将测试之间的偏移量重置为最新而不是丢弃整个上下文来提高性能，而不仅仅是使用@DirtiesContext我的build.gradle是： import org.springframework.boot.gradle.plugin.SpringBootPlugin
id 'org.springframework.boot:spring-integration-core'
浏览 37提问于2020-11-04得票数 4
回答已采纳
我现在使用的是spring boot 2和JUnit5。我想使用spring-kafka-test进行测试，但是我使用的spring-kafka版本是2.1.8版本。因此我认为不可能使用EmbeddedKafkaBroker，因为它是2.2.x中的东西。 我使用的kafka客户端是1.1.0。我看了一下https://spring.io/projects/spring-kafka中提到的兼容性矩阵，它似乎不适用于client 1.
浏览 26提问于2019-01-24得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号