我正在尝试使用scala为kafka编写一个简单的avro消息生成器。
我遇到的问题是发送速度很慢。
我是这样做的：

val message: GenericRecord = getRandomMessage()
val serializedMessage: Array[Byte] = serializeMessage(message)

val queueMessage = new ProducerRecord[String, Array[Byte]](topic, message.get("id").toString, serializedMessage)
producer.send(queueMessage)
println("Sent Message: "+ message)

无论是部署到集群还是从ide运行，发送消息的速度都非常慢。
从我所读到的信息应该是异步的，而且比这个更快。
我有什么明显的遗漏吗？
谢谢！