最近，我们安装了由ambari安装的新kafka集群（版本2.0.0）。我们有多个主题，比如前缀{yyyy-mm-dd}，它们是每天创建的，删除两周前的主题。因此，在大多数情况下，存在14个主题，但只有1个主题接收数据。我们的程序以“前缀.*”的模式订阅主题。问题是它的消耗非常慢。当我们将模式替换为固定的1个主题（如前缀\u 2020-09-28）时，效果很好。我认为可能的原因可能是它订阅了14个主题，尽管其中13个没有任何新的数据。但是我们的老kafka集群（版本1.0.1）在同样的情况下工作得很好。有什么办法解决这个问题吗？非常感谢你！
p、 我们用flume和flink来消费Kafka，他们都有这个问题。