Skip to content

Commit b09969e

Browse files
committed
Reverted more changes to reduce the diff
1 parent faff845 commit b09969e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/producer/base.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,8 +79,8 @@ def _send_upstream(queue, client, codec, batch_time, batch_size,
7979
client.send_produce_request(reqs,
8080
acks=req_acks,
8181
timeout=ack_timeout)
82-
except:
83-
log.exception('Failed to send messages to Kafka. Batch size: {0}. Topics: {1}'.format(len(reqs), topics))
82+
except Exception:
83+
log.exception("Unable to send message")
8484

8585

8686
class Producer(object):

0 commit comments

Comments
 (0)