java kafka流在升级到springkafka:2.5.3后停止工作。释放
我正在尝试将Spring boot应用程序升级到2.5.0版
升级后:
plugins {
id 'org.springframework.boot' version '2.5.0'
}
我说了一个错误
Failed to introspect Class [org.springframework.boot.actuate.autoconfigure.metrics.KafkaMetricsAutoConfiguration$KafkaStreamsMetricsConfiguration]
检查这个类时,我发现它确实被破坏了,因为下面代码中的“addListener”无法解析
static class KafkaStreamsMetricsConfiguration {
@Bean
StreamsBuilderFactoryBeanCustomizer kafkaStreamsMetrics(MeterRegistry meterRegistry) {
return (factoryBean) -> factoryBean.addListener(new KafkaStreamsMicrometerListener(meterRegistry));
}
}
上面的代码来自spring boot actuator自动配置:2.5.0 jar
如果将我的spring kafka dependency更新到2.5.2以上的任何版本,这个问题就会得到解决。释放
例如:
implementation 'org.springframework.kafka:spring-kafka:2.5.3.RELEASE'
“addListener”现在取自spring-kafka-2.5.3下的StreamsBuilderFactoryBean。释放罐子
真正的问题是,出于某种原因,这一更改使Kafka stream bean无法运行,并且没有进行消费。它似乎以某种方式打破了卡夫卡音乐的春天活力。没有任何类型的错误,也没有任何迹象表明出现了问题。感觉像是残疾
其他一些信息:
我在用
implementation 'org.apache.kafka:kafka-streams:2.5.0'
implementation 'org.apache.kafka:kafka-clients:2.5.0'
改变他们的版本似乎没有任何效果
假设没有其他变化(应用程序类和卡夫卡配置)——原因可能是什么
# 1 楼答案
不应指定版本;让Boot的依赖关系管理来管理版本。目前的Boot 2.5版本是2.5.7;它需要spring kafka 2.7.9——有关依赖关系矩阵,请参见项目页面
https://spring.io/projects/spring-kafka