We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b053da2 commit b81bf5fCopy full SHA for b81bf5f
test/test_consumer_integration.py
@@ -220,7 +220,7 @@ def test_offset_behavior__resuming_behavior(self):
220
221
# Start a consumer
222
consumer1 = self.consumer(
223
- auto_commit_every_t = 600,
+ auto_commit_every_t = None,
224
auto_commit_every_n = 20,
225
)
226
@@ -230,7 +230,7 @@ def test_offset_behavior__resuming_behavior(self):
230
231
# The total offset across both partitions should be at 180
232
consumer2 = self.consumer(
233
234
235
236
0 commit comments