从有帮助的信息中抄袭而来,我正在尝试运行一个单元测试,以演示在同一主题的同一组中的多个成员之间的消息分布。我刚开始使用Kafka,所以我可能遗漏了一些基本的东西。per topic - to support up to 3 consumers in a group public static KafkaEmbedded embeddedKafka(): " + embeddedKafka.getPartitionsPerTopic());
Conta
我有一个Spring Kafka项目,我已经为它写了一些单元测试。当我执行测试类时,项目尝试使用实际的Kafka代理,而不是测试类中注释的嵌入式Kafka代理。@RunWith(SpringRunner.class)@EmbeddedKafkapublic class SpringKafkaReceiverTest
version 1.0.0.RELEASE,该应用程序使用来自Kakfa 0.9集群的消息。我为我的使用者进行了一个单元测试,它使用了KafkaEmbedded,但是由于代理端口是随机获取的,所以它失败了。我是否可以在不更改版本的情况下设置这个代理属性?或者我应该使用哪些版本来避免破坏任何东西? public void init(){
System.setPr