Change auto_commit to False in SimpleConsumer
Also start a change log for important stuff like this Closes #34
This commit is contained in:
1
.gitignore
vendored
1
.gitignore
vendored
@@ -4,3 +4,4 @@
|
||||
build
|
||||
dist
|
||||
MANIFEST
|
||||
env
|
||||
|
||||
3
CHANGES.md
Normal file
3
CHANGES.md
Normal file
@@ -0,0 +1,3 @@
|
||||
# Notable Changes
|
||||
|
||||
* Changing auto_commit to False in [SimpleConsumer](kafka/SimpleConsumer.py), until 0.8.1 is release offset commits are unsupported
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user