要解决Alpakka消费者无法从通过Docker Compose运行的Kafka消费消息的问题，你可以按照以下步骤进行操作：

1. 确保在Docker Compose文件中正确配置了Kafka服务。 在docker-compose.yml文件中添加以下配置：

   version: '3'
   services:
     kafka:
       image: wurstmeister/kafka
       ports:
         - "9092:9092"
       environment:
         KAFKA_ADVERTISED_HOST_NAME: localhost
       volumes:
         - /var/run/docker.sock:/var/run/docker.sock
   

2. 确保Alpakka消费者的配置与Kafka服务的配置匹配。 在Alpakka消费者的配置文件中，确保以下属性与Kafka服务的配置一致：

   val kafkaConfig = ConfigFactory.parseString(
     """
     akka.kafka.consumer {
       # Kafka bootstrap servers
       kafka-clients.bootstrap.servers = "localhost:9092"
     }
     """
   )
   

3. 确保Alpakka消费者能够连接到Kafka服务。 在Alpakka消费者的代码中，确保以下代码可以成功连接到Kafka服务：

   val bootstrapServers = "localhost:9092"
   val consumerSettings = ConsumerSettings(system, new StringDeserializer, new StringDeserializer)
     .withBootstrapServers(bootstrapServers)
   

4. 确保Alpakka消费者使用正确的主题订阅消息。 在Alpakka消费者的代码中，确保以下代码使用正确的主题订阅消息：

   val topic = "my-topic"
   val subscription = Subscriptions.topics(topic)
   val kafkaSource: Source[ConsumerRecord[String, String], Consumer.Control] =
     Consumer.plainSource(consumerSettings, subscription)
   

5. 确保Alpakka消费者能够处理接收到的消息。 在Alpakka消费者的代码中，确保已经实现了对接收到的消息的处理逻辑：

   val kafkaConsumerLogic: Flow[ConsumerRecord[String, String], ConsumerRecord[String, String], NotUsed] =
     Flow[ConsumerRecord[String, String]].map { record =>
       // 处理接收到的消息的逻辑
       println(s"Received message: ${record.value()}")
       record
     }
   val kafkaStream: RunnableGraph[Consumer.Control] =
     kafkaSource.via(kafkaConsumerLogic).to(Sink.ignore)
   

通过上述步骤，你可以解决Alpakka消费者无法从通过Docker Compose运行的Kafka消费消息的问题。确保配置和代码正确，并且Alpakka消费者能够成功连接到Kafka服务并处理接收到的消息。