小编gno*_*nos的帖子

Spring bean依赖于条件bean

我想要一个spring bean 在另一个bean之后进行实例化.所以我只是使用@DependsOn注释.

问题是:这个其他bean是一个带有@ConditionalOnProperty(name = "some.property", havingValue = "true")注释的条件bean .因此,当属性为false时,bean不会被实例化(这就是我们想要的),并且@DependsOn显然会失败.这里的目标是:无论如何创建第二个bean,但是如果它被创建,则在第一个bean之后创建它.

有没有办法做到这一点,而不删除@ConditionalOnProperty?并且没有玩@Order注释?

谢谢您的帮助

java spring spring-boot

10
推荐指数
3
解决办法
2903
查看次数

使用弹簧执行器(普罗米修斯)公开 kafka 流指标

我正在使用 Springboot 2 运行 Kafka Stream 应用程序。

我想让我的 kafka 流指标以普罗米修斯格式提供 host:8080/actuator/prometheus

我没办法拥有这个。我不确定我是否了解 kafka 流指标是如何导出的。能actuator得到这些JMX指标?有没有办法获取这些指标并以 Prometheus 格式公开它们?

PS:也没有与 java jmx_prometheus_agent 一起工作

有人有解决方案或示例吗?

谢谢

spring-boot-actuator apache-kafka-streams

7
推荐指数
2
解决办法
551
查看次数

intellij GWT调试配置

如何覆盖默认服务器intellij的GWT调试配置?Intellij将Jetty作为默认服务器,但我希望它使用jboss服务器.

我尝试使用Jetty服务器,但我遇到了类似身份验证的错误......

在此输入图像描述

有人知道如何覆盖默认服务器,或者为什么我使用Jetty得到这种错误?

java debugging gwt intellij-idea

6
推荐指数
1
解决办法
885
查看次数

如何对使用会话窗口的Kafka流应用程序进行单元测试

我正在使用Kafka Stream 2.1

我正在尝试为流应用程序编写一些测试,该应用程序使用会话间隔为300ms的会话窗口按事件的键(即相关ID)聚合某些事件。

这是由方法表示的聚合实现:

    private static final int INACTIVITY_GAP = 300;

    public KStream<String, AggregatedCustomObject> aggregate(KStream<String, CustomObject> source) {

        return source
                // group by key (i.e by correlation ID)
                .groupByKey(Grouped.with(Serdes.String(), new CustomSerde()))
                // Define a session window with an inactivity gap of 300 ms
                .windowedBy(SessionWindows.with(Duration.ofMillis(INACTIVITY_GAP)).grace(Duration.ofMillis(INACTIVITY_GAP)))
                .aggregate(
                        // initializer
                        () -> new AggregatedCustomObject(),
                        // aggregates records in same session
                        (s, customObject, aggCustomObject) -> {
                            // ...
                            return aggCustomObject;
                        },
                        // merge sessions
                        (s, aggCustomObject1, aggCustomObject2) -> {
                            // ...
                            return aggCustomObject2; …
Run Code Online (Sandbox Code Playgroud)

java unit-testing windowing apache-kafka-streams

6
推荐指数
1
解决办法
167
查看次数