producer.send atomic?

[Kane Kane]

Hello, as I understand send is not atomic, i.e. i have something like this
in my code:

    val requests = new ArrayBuffer[KeyedMessage[AnyRef, AnyRef]]
    for (message <- messages) {
      requests += new KeyedMessage(topic, null, message, message)
    }
    producer.send(requests)

That means batch can die in the middle?
Also what happens if during this write the broker that has some partition
leaders will die? The same question for consumer, what happens if broker
dies while consumer reading from it?

Thanks.