我在alpakka项目的基础上构建了一个非常简单的akka流，但是它没有阅读kafka的任何内容，即使它连接并创建了一个消费群体。我已经为流创建了一个隐式的actor系统和materializer。

val done = Consumer.committableSource(consumerSettings,
Subscriptions.topics(kafkaTopic))
.map(msg => msg.committableOffset)
.mapAsync(1) { offset =>
offset.commitScaladsl()
}
.runWith(Sink.ignore)

[stream.actor.dispatcher]将此消息发送给kafkaconsumeractor“请求消息，请求ID:1，分区：set（kafka-topic-0）”
kafkaconsumerator似乎没有收到消息，但是当主管要求参与者关机时，它确实收到了消息并关机。
有什么线索能解释为什么Kafka没有错误或例外？