@staticmethod<EOL><INDENT>def delivery_report(err, msg):<DEDENT>
if err is not None:<EOL><INDENT>log.exception(u'<STR_LIT>'.format(err))<EOL>raise confluent_kafka.KafkaException(err)<EOL><DEDENT>else:<EOL><INDENT>log.debug(u'<STR_LIT>'.format(<EOL>msg.topic(), msg.partition(), msg.value()))<EOL><DEDENT>
Callback called once for each produced message to indicate the final
delivery result. Triggered by poll() or flush().

:param confluent_kafka.KafkaError err: Information about any error
that occurred whilst producing the message.
:param confluent_kafka.Message msg: Information about the message
produced.
:returns: None
:raises confluent_kafka.KafkaException