Kafka版本:3.0.1-Kafka管理客户端反复创建-内存泄漏

Question

我们有一个跳转应用程序，它从一个主题消耗，并生成记录到多个主题。

最近，在gradle项目中，这个应用程序升级到Sprinboot-2.6.7和其他依赖项。

应用程序能够正确消费和生产，，但问题是它似乎反复创建卡夫卡管理客户端(1000 S)，并且似乎正在泄漏内存(可能是由于这个原因？)，最终导致实例崩溃，无法跟上滞后。

外部库中与kafka相关的依赖jars

   org.apache.kafka:kafka-clients:3.0.1   
   org.springframework.cloud:spring-cloud-stream:3.2.3   
   org.springframework.cloud:spring-cloud-stream-binder-kafka:3.2.3   
   org.springframework.cloud:spring-cloud-stream-binder-kafka-core:3.2.3    
   org.springframework.integration:spring-integration-kafka:5.5.11    
   org.springframework.kafka:spring-kafka:2.8.5   

​

​

这有什么原因吗？缺少配置？

Answer 1

所以adminClient不是问题所在。问题来自存储输出通道的hashmap的默认大小10。我已经设置了spring.cloud.stream.dynamic-destination-cache-size=30，，因为我们已经在app中设置了大约17个输出目的地。如果这个hashmap "StreamBridge.channelCache“的默认大小为10，它将不断删除和添加要映射的值，”一旦达到此大小，新的目的地将触发删除旧目标“，不时调用GC。

​

​