diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | AUTHORS.md | 1 | ||||
| -rw-r--r-- | CHANGES.md | 3 | ||||
| -rw-r--r-- | kafka/consumer.py | 2 |
4 files changed, 6 insertions, 1 deletions
@@ -4,3 +4,4 @@ build dist MANIFEST +env @@ -4,6 +4,7 @@ Ordered by contribution * David Arthur, [@mumrah](https://github.com/mumrah) * Mahendra M, [@mahendra](https://github.com/mahendra) +* Ivan Pouzyrevsky, [@sandello](https://github.com/sandello) * [@anentropic](https://github.com/anentropic) * Ben Frederickson, [@benfred](https://github.com/benfred) diff --git a/CHANGES.md b/CHANGES.md new file mode 100644 index 0000000..485c880 --- /dev/null +++ b/CHANGES.md @@ -0,0 +1,3 @@ +# Notable Changes + +* Changing auto_commit to False in [SimpleConsumer](kafka/consumer.py), until 0.8.1 is release offset commits are unsupported diff --git a/kafka/consumer.py b/kafka/consumer.py index f8855dc..db7a793 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -38,7 +38,7 @@ class SimpleConsumer(object): these triggers """ - def __init__(self, client, group, topic, auto_commit=True, + def __init__(self, client, group, topic, auto_commit=False, auto_commit_every_n=AUTO_COMMIT_MSG_COUNT, auto_commit_every_t=AUTO_COMMIT_INTERVAL): self.client = client |