how to ensure message not missing

[zuiwanting]

we have a kafka cluster with 5 nodes, and producer gen through method 'get_producer', when we restart one node, the producer got error message bellow:

• pykafka.OwnedBroker.queue_reader for broker 4] Message not delivered!! SocketDisconnectedError()
• pykafka.OwnedBroker.queue_reader for broker 2] Message not delivered!! NotLeaderForPartition

in this situation, how we can identify which message missing or retry to send the missing message when the broken kafka broker is working