From 0f89ee91758ce144e8c2416b5481f7967b7857a8 Mon Sep 17 00:00:00 2001 From: Berkodev Date: Tue, 13 Mar 2018 19:23:40 +0200 Subject: [PATCH 1/2] Adds add_callback/add_errback example to docs --- docs/usage.rst | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/docs/usage.rst b/docs/usage.rst index 22fe20d5c..f30b9523a 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -91,6 +91,18 @@ KafkaProducer for _ in range(100): producer.send('my-topic', b'msg') + def on_send_success(record_metadata): + print(record_metadata.topic) + print(record_metadata.partition) + print(record_metadata.offset) + + def on_send_error(excp): + log.exception() + # handle exception + + # produce asynchronously with callbacks + producer.send('my-topic', b'raw_bytes').add_callback(on_send_success).add_errback(on_send_error) + # block until all async messages are sent producer.flush() From ba33bb82e9d80a44851c3be8f4abf446e872c594 Mon Sep 17 00:00:00 2001 From: Berkodev Date: Thu, 29 Mar 2018 18:30:25 +0300 Subject: [PATCH 2/2] Fixes errback example in docs --- docs/usage.rst | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/usage.rst b/docs/usage.rst index f30b9523a..1cf1aa414 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -97,7 +97,7 @@ KafkaProducer print(record_metadata.offset) def on_send_error(excp): - log.exception() + log.error('I am an errback', exc_info=excp) # handle exception # produce asynchronously with callbacks