1回答
我正面临着一个问题，我的Kafka ProducerConfig获取了一个无效的bootstrap.servers值，因为我的单元测试@PropertySource没有解析spring.embedded.kafka.brokers当我将我的生产者配置转储到日志中时，我得到了以下信息：batch.size = 10000
bootstrap.servers = [${spring.embedded.kafka.brokersSpringBootTest
浏览 5提问于2019-03-06得票数 0
我有一个Spring Kafka项目，我已经为它写了一些单元测试。当我执行测试类时，项目尝试使用实际的Kafka代理，而不是测试类中注释的嵌入式Kafka代理。我尝试的是签入gitlab --> https://gitlab.com/mohammad.mnajar/spring-kafka-unit-test 任何帮助都将不胜感激。
浏览 22提问于2019-07-01得票数 0
1回答
弹簧启动嵌入式卡夫卡无法连接
、、、、
我已经完成了测试，但是当我开始测试时，我只看到这个重复的无限的结果：
我在我的@EnableKafka类上有了@Configuration注释。key-deserializer: org.apache.kafka.comm
浏览 1提问于2019-04-03得票数 5
回答已采纳
1回答
内存服务器中的Spring是以随机端口启动的。因此，application.yml条目是一个变量：但是，只有当嵌入式Kafka服务器实际运行时在没有嵌入式Kafka异常的单元测试中，会抛出异常(因为实际上没有设置变量)：
java.lang.IllegalStateException: Failed to load ApplicationConte
浏览 2提问于2019-03-18得票数 0
回答已采纳
1回答
我们使用的是@EmbeddedKafka，在application-test.yml中我们有 confluentBootstrapAddress: ${spring.embedded.kafka.brokers但是，如果在调试模式下选中此选项然后我可
浏览 1提问于2021-03-30得票数 0
为了通过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 produc
浏览 100提问于2021-06-16得票数 0
回答已采纳
我正在为我的Spring应用程序编写Junit测试用例(使用@EmbeddedKafka)，该应用程序广泛使用Spring与其他服务和其他操作进行通信。一个典型的例子是从kafka中删除数据(我们正在使用kafka中的空消息进行删除)。为上述方法逻辑编写Junit时遵循的步骤。@Test //Push
浏览 2提问于2019-01-31得票数 1
1回答
我使用Spring和@EmbeddedKafka注释来启动嵌入的Kafka实例。受抚养人： <groupId>org.springframework.kafka</groupId> <scope>test</scope>
</depend
浏览 1提问于2019-04-10得票数 4
回答已采纳
3回答
在spring引导应用程序中，我正在使用Spring-Kak-2.2.0编写集成测试，虽然我的测试用例仍然返回true，但在那之后我仍然看到了多个错误。2019-02-21 11:12:35.434 ERROR 5717 --- [ Thread-7] kafka.server.ReplicaManager : [Error while writing to highwatermark file in directory /var/folders/s3/rz83x
浏览 0提问于2019-02-21得票数 16
回答已采纳
1回答
DirtiesContext @EmbeddedKafka(分区= 1，主题= {EmbeddedKafkaIntegrationTest.TEST_TOPIC}，bootstrapServersProperty =“Spring.kafka.bootstra-Servers}")@Value("${spring.kafka.consumer.auto-offset-reset}")
private String offsetResetStri
浏览 23提问于2022-10-17得票数 0
我是Spring和Kafka的新手。我正在做一个使用SpringBoot-kafka的用例，允许用户在运行时创建kafka主题。spring应用程序期望在运行时以编程方式订阅这些主题。到目前为止，我所知道的是，Kafka listener是设计时，因此在启动之前需要指定主题。有没有办法在SpringBoot-Kafka集成中动态订阅kafka主题？已引用此
我计划实现的当前方法是，不要使用S
浏览 0提问于2017-01-08得票数 11
1回答
我在我的应用程序中使用流桥，因为要发送的主题是在运行时根据URL路径参数确定的；我从请求体、路径元素和调用流桥发送到一个函数，以便发布到Kafkapublic RouterFunction: banner-mode: off embedded: data:
mongodb:(DefaultKafkaProducerFactory.java:1087) ~[spring-kafka-2.
浏览 23提问于2022-07-11得票数 0
回答已采纳
我正在尝试为我正在使用Spring Boot2.x开发的Kafka侦听器编写单元测试。作为一个单元测试，我不想启动一个完整的Kafka服务器，一个Zookeeper的实例。因此，我决定使用Spring嵌入式Kafka。@DirtiesContext@TestPropertySource(properti
浏览 0提问于2018-05-02得票数 20
回答已采纳
对于Java/Kotlin Spring启动应用程序，如果我想向Kafka发送消息或使用来自Kafka的消息。你会推荐使用Spring Kafka库还是只使用Kafka Java API。不太确定Spring提供了更多的好处，还是仅仅是一个包装器？对于Spring，它们提供了很多注释，当出现一些运行时错误时，这些注释看起来更神奇。
想听听你的意见。
浏览 5提问于2018-07-28得票数 1
回答已采纳
我正在使用spring Kafka的应用程序中设置用于JUnit测试的Embedded-Kafka。为zookeeper日志目录设置的位置/属性是什么。使用Embedded-Kafka时，默认情况下我没有名为server.properties或zookeeper.properties的文件，它会在Windows上的临时文件夹中创建日志文件，但我的临时窗口是有限制的，所以我得到了一个异常 我可以使用以下命令指定Kafka日志目录 @EmbeddedKafka(b
浏览 23提问于2019-04-19得票数 2
我用流桥发送卡夫卡消息然而，我的测试无法连接到卡夫卡经纪人。2022-07-12 12:29:41.095 WARN 79618 --- [read | consumer] org.apache.kafka.clients.NetworkClient :(KafkaTestUtils.java:181)
at org.springframework.kafka.test.utils.K
浏览 9提问于2022-07-12得票数 0
回答已采纳
1回答
我正在尝试用spring boot对kafka的使用进行单元测试，但在输入通道上遇到了问题。下面是我正在做的事情的摘录。
浏览 89提问于2020-03-27得票数 1
回答已采纳
boot自动配置启动bean所需的属性？我既有spring.kafka属性组，也有通过KafkaHandlerConfiguration中的@Value注释注入的自定义属性 @Value("${digite.swiftalk.kafka.executor.core-pool-sizequeueCapacity; 和 "spring.kafka.producer.properties.max.block.ms=1000",
"
浏览 44提问于2021-03-31得票数 0
回答已采纳
我正在尝试运行spring-kafka集成。当我尝试启动Spring boot时，我得到下面的错误消息。根据上面的链接，4.3与Kafka 1.1 onwards.Has兼容任何人都尝试过这种组合。</groupId> <version>1.2.0.RELEA
浏览 0提问于2017-04-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
