我想要一个spring bean 在另一个bean之后进行实例化.所以我只是使用@DependsOn注释.
问题是:这个其他bean是一个带有@ConditionalOnProperty(name = "some.property", havingValue = "true")注释的条件bean
.因此,当属性为false时,bean不会被实例化(这就是我们想要的),并且@DependsOn显然会失败.这里的目标是:无论如何创建第二个bean,但是如果它被创建,则在第一个bean之后创建它.
有没有办法做到这一点,而不删除@ConditionalOnProperty?并且没有玩@Order注释?
谢谢您的帮助
我正在使用 Springboot 2 运行 Kafka Stream 应用程序。
我想让我的 kafka 流指标以普罗米修斯格式提供 host:8080/actuator/prometheus
我没办法拥有这个。我不确定我是否了解 kafka 流指标是如何导出的。能actuator得到这些JMX指标?有没有办法获取这些指标并以 Prometheus 格式公开它们?
PS:也没有与 java jmx_prometheus_agent 一起工作
有人有解决方案或示例吗?
谢谢
如何覆盖默认服务器intellij的GWT调试配置?Intellij将Jetty作为默认服务器,但我希望它使用jboss服务器.
我尝试使用Jetty服务器,但我遇到了类似身份验证的错误......
有人知道如何覆盖默认服务器,或者为什么我使用Jetty得到这种错误?
我正在使用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)