在Akka Streams中，可以使用Source.queue来创建一个无界队列。下面是一个示例代码：

import akka.actor.ActorSystem
import akka.stream.scaladsl.{Sink, Source}

import scala.concurrent.Future

object UnboundedQueueExample extends App {
  implicit val system: ActorSystem = ActorSystem("UnboundedQueueExample")

  // 创建一个无界队列
  val queue = Source.queue[Int](bufferSize = Int.MaxValue, overflowStrategy = akka.stream.OverflowStrategy.fail)
  
  // 生产者
  val producer = queue
    .map(i => {
      println(s"Producing element: $i")
      i
    })
    .to(Sink.ignore)
    .run()

  // 消费者
  val consumer = queue
    .map(i => {
      println(s"Consuming element: $i")
      i
    })
    .to(Sink.foreach(println))
    .run()

  // 生产数据
  (1 to 10).foreach { i =>
    producer.offer(i)
    Thread.sleep(100)
  }

  // 等待所有数据被消费
  Thread.sleep(1000)

  // 关闭ActorSystem
  Future.sequence(Seq(producer, consumer))
    .flatMap(_ => system.terminate())
    .onComplete(_ => println("ActorSystem terminated"))
}

这个示例创建了一个无界队列，并通过一个生产者和一个消费者来演示数据的生产和消费过程。在生产者中，我们使用offer方法将数据推送到队列中，而在消费者中，我们通过run方法将数据从队列中消费出来。最后要记得关闭ActorSystem，以确保程序正常退出。

请注意，这个示例中，我们使用bufferSize = Int.MaxValue来表示队列是无界的。这样可以确保队列不会因为缓冲区满而阻塞。同时，我们使用了OverflowStrategy.fail作为溢出策略，这意味着当队列已满时，生产者将抛出BufferOverflowException异常。你可以根据实际需要选择合适的溢出策略。