Kafka Streams应用程序在kafka服务器上打开了太多文件

Question

我一直在研究基于java kafka-streams API的应用程序，其目标是处理来自一个kafka主题的数据流，并将其生成另一个主题。

看起来，每当我开始使用kafka-streams应用程序生成消息时，文件句柄只会继续打开我正在使用的kafka代理，并且它们永远不会关闭，这意味着最终kafka服务器最终会打开太多的文件，并且kafka和zookeeper守护进程崩溃。

我正在使用kafka-streams-1.0.1 API jar for Java，并在JDK 11上运行.kafka集群是Kafka版本1.0.0。

我的应用程序的配置包括以下kafka生产者配置：

流处理本身非常简单，并且组成：

stream.map((k,v) -> handle(k,v)).filter((k,v) -> v != null).to(outgoingTopic);

我很感激你们的任何建议。