0

我正在使用带有 Kafka 和弹性的 Spring Boot 为 Groovy 创建一个演示应用程序。我在 Spock 测试中使用了 @EmbeddedKafka 注释，它们在本地工作得非常好；在 Windows 和 Ubuntu 上。它们通过运行或调试在 Intellij 中工作，没有问题。在我的外壳“./gradlew test”中尝试时也是如此。万事皆安。一旦我将它推送到 github.com，我的 github 操作就失败了。但它正在调用相同的命令。

动作定义：https ://github.com/besessener/GroovySpringBootKafkaElasticsearchDemo/blob/main/.github/workflows/test.yml

远程失败测试用例： https ://github.com/besessener/GroovySpringBootKafkaElasticsearchDemo/blob/main/src/test/groovy/me/spring/GroovyDemo/stream/KafkaSendAndReceiveTest.groovy

行动：https ://github.com/besessener/GroovySpringBootKafkaElasticsearchDemo/runs/3019862203?check_suite_focus=true

从操作输出来看，对我来说唯一看起来像错误的是：

 2021-07-08 14:05:35.896  WARN 2693 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-UserGroup-1, groupId=UserGroup] Error while fetching metadata with correlation id 4 : {topic-user=LEADER_NOT_AVAILABLE}

我读了很多关于不使用静态端口进行 kafka 测试的内容。但这是我唯一的 kafka 测试，所以我不太明白应该如何发生冲突。此外，LEADER_NOT_AVAILABLE 可能是不存在主题的问题，或者消费者可能根本无法正确连接到代理。但我没有看到任何这些。

我仍然觉得它与 "localhost:9092" 作为 brokerProperties 更相关。使用 Github 操作时是否有这方面的问题？或者我还缺少什么？

4

0 回答 0