Index: core/src/main/scala/kafka/producer/Producer.scala
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- core/src/main/scala/kafka/producer/Producer.scala	(revision 15bb3961d9171c1c54c4c840a554ce2c76168163)
+++ core/src/main/scala/kafka/producer/Producer.scala	(revision )
@@ -66,6 +66,9 @@
    * Sends the data, partitioned by key to the topic using either the
    * synchronous or the asynchronous producer
    * @param messages the producer data object that encapsulates the topic, key and message data
+   * @throws ProducerClosedException if producer is already closed
+   * @throws QueueFullException if async sending queued more messages than specified by config#queueBufferingMaxMessages
+   * @throws FailedToSendMessageException if sync sending of at least one of the messages failed
    */
   def send(messages: KeyedMessage[K,V]*) {
     lock synchronized {
Index: core/src/main/scala/kafka/javaapi/producer/Producer.scala
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- core/src/main/scala/kafka/javaapi/producer/Producer.scala	(revision 15bb3961d9171c1c54c4c840a554ce2c76168163)
+++ core/src/main/scala/kafka/javaapi/producer/Producer.scala	(revision )
@@ -28,6 +28,9 @@
    * Sends the data to a single topic, partitioned by key, using either the
    * synchronous or the asynchronous producer
    * @param message the producer data object that encapsulates the topic, key and message data
+   * @throws ProducerClosedException if producer is already closed
+   * @throws QueueFullException if async sending queued more messages than specified by config#queueBufferingMaxMessages
+   * @throws FailedToSendMessageException if sync sending of at least one of the messages failed
    */
   def send(message: KeyedMessage[K,V]) {
     underlying.send(message)
@@ -36,6 +39,9 @@
   /**
    * Use this API to send data to multiple topics
    * @param messages list of producer data objects that encapsulate the topic, key and message data
+   * @throws ProducerClosedException if producer is already closed
+   * @throws QueueFullException if async sending queued more messages than specified by config#queueBufferingMaxMessages
+   * @throws FailedToSendMessageException if sync sending of at least one of the messages failed
    */
   def send(messages: java.util.List[KeyedMessage[K,V]]) {
     import collection.JavaConversions._