这个问题可能是由于以下原因引起的：

1. Kafka 消费者配置错误。

2. Kafka 主题消息数量太少。

3. 消费者处理逻辑的错误

针对这个问题，可以考虑以下解决方案：

1. 确认 Kafka 消费者配置是否正确。 如果配置不正确可能会导致消费者在一段时间后关闭。

以下是一个正确且典型的 Kafka 消费者代码示例：

import akka.actor.ActorSystem
import akka.kafka.scaladsl.Consumer
import akka.kafka.{ConsumerSettings, Subscriptions}
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Sink
import org.apache.kafka.common.serialization.StringDeserializer

object KafkaConsumerExample extends App {
  implicit val system = ActorSystem("kafka-example")
  implicit val materializer = ActorMaterializer()
  val bootstrapServers = "localhost:9092"
  val consumerSettings = ConsumerSettings(system, new StringDeserializer, new StringDeserializer)
    .withBootstrapServers(bootstrapServers)
    .withGroupId("group1")
  val topic = "topic1"
  Consumer.plainSource(consumerSettings, Subscriptions.topics(topic))
    .map(record => println(s"Consumed topic = ${record.topic}, partition = ${record.partition}, offset = ${record.offset}, key = ${record.key}, value = ${record.value}"))
    .runWith(Sink.ignore)
}

2. 确认 Kafka 主题消息数量。 如果主题消息数量太少，可能会导致消费者在几秒钟内完成消息消费并关闭。

3. 检查消费者处理逻辑是否正确。 可能需要更改代码以确保消费者一直处于运行状态。 可以添加日志记录检查消费者何时停止。

最后，建议查看 Kafka 官方文档以获得更多有关 Kafka 消费者配置和使用的信息。