This repository was archived by the owner on Mar 24, 2021. It is now read-only.
Annoying autocommitting log #337
Assignees
Labels
Comments
emmettbutler
added a commit
that referenced
this issue
Nov 11, 2015
yungchin
added a commit
that referenced
this issue
Nov 13, 2015
…tension The producer-futures feature was backed out of master, which means the expected interface for RdKafkaProducer._produce() has changed back, too. I've addressed all merge conflicts here - the change in the _produce() interface will be addressed in the next commit. * parsely/master: (26 commits) changelog updates for 2.0.3, dev version increment version Catch IOError in recvall_into util. Catch IOError during connection response. re-import weakref Revert 52ae7a1 Link #334 to README. drop autocommit logging to DEBUG level. fixes #337 update after socket error in offset manager discovery remove unused condition unconditionally update partition leaders on update Load all topic values on values method. fix typo causing interpreter error in reset_offsets` fix outdenting error clarify functools import catch all exceptions when removing from zookeeper be very specific about the error we expect producer: minimal changes for gc'ability balancedconsumer: minimal changes for gc'ability (RFC) add logging, fix some retry/reconnect/update logic in simpleconsumer ... Signed-off-by: Yung-Chin Oei <[email protected]> Conflicts: .travis.yml pykafka/simpleconsumer.py tests/pykafka/test_producer.py
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
The autocommitting log here is logged every N millseconds, it is a bit annoying to me when N is small(like 1000ms), can we lower down it to DEBUG level?
The text was updated successfully, but these errors were encountered: