我正在测试kafka producer中的async send（）。我要连接到的群集处于脱机状态。我的假设是我可以快速发送10000个请求（listtosend的长度）。下一个超时（60秒）将开始，60秒后我会看到回调击中我 logger.error(s"failed to send record ${x._2}", e) 然而，这个方法似乎要花很长时间才能完成。
这就是为什么我在 logger.debug("test: am I sending data") 线路。
它打印出来，然后在60秒内什么也没发生。我看到第一条记录的回调失败。只有这样，它才会继续前进。
这是正常的行为还是我遗漏了一些基本的东西？

listToSend.foreach { x =>
        logger.debug("test: am I sending data")
        // note: I added this 'val future =' in an attempt to fix this, to no avail
        val future = producer.send(new ProducerRecord[String, String](topic, x._2), new Callback {
          override def onCompletion(metadata: RecordMetadata, e: Exception) {

            if (e != null) {
              //todo: handle failed sends, timeouts, ...
              logger.error(s"failed to send record ${x._2}", e)
            }
            else { //nice to have: implement logic here, or call another method to process metadata
              logger.debug("~Callback success~")
            }
          }
        }
        )
      }

注意：我不想阻止这段代码，我想保持它的异步。但是它似乎在send（）上被阻塞。