Skip to content

kafkatest, refactoring, and bug fixes #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
edenhill merged 13 commits into from
May 10, 2016
Merged

kafkatest, refactoring, and bug fixes #1

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
77305ff
Added (global) on_commit callback.
edenhill Apr 25, 2016
5433bb8
Raise exception on rebalance_cb arg building failure
edenhill Apr 25, 2016
4592b31
Improved error formatting
edenhill Apr 25, 2016
6d90fa7
Renamed producer delivery_callback to on_delivery
edenhill Apr 29, 2016
e9c9570
Minor formatting cleanup
edenhill Apr 29, 2016
b520c8d
Adjust consumer test error codes and timeouts
edenhill Apr 29, 2016
b2568b4
Restructured: C bindings are now a submodule (cimpl)
edenhill Apr 29, 2016
0dad9ef
Added kafkatest verifiable consumer and producer
edenhill Apr 29, 2016
99b774b
on_commit(): removed consumer arg
edenhill May 9, 2016
e6d3877
Minor modifications following Ewen's code review
edenhill May 9, 2016
6936d9f
Moved sources to src/ to avoid cimpl package collision
edenhill May 9, 2016
ee588bf
Minor cleanups
edenhill May 9, 2016
f853b46
test_docs: dont require module docs (cimpl)
edenhill May 9, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Adjust consumer test error codes and timeouts
  • Loading branch information
@edenhill
edenhill committed Apr 29, 2016
commit b520c8d92e8f371a5cc85d3a2bb27dd12a62309f
3 changes: 2 additions & 1 deletion tests/test_Consumer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ def dummy_commit_cb (consumer, err, partitions):
pass

kc = Consumer({'group.id':'test', 'socket.timeout.ms':'100',
'session.timeout.ms': 1000, # Avoid close() blocking too long
'on_commit': dummy_commit_cb})

kc.subscribe(["test"])
Expand Down Expand Up @@ -45,7 +46,7 @@ def dummy_assign_revoke (consumer, partitions):
try:
kc.commit(async=False)
except KafkaException as e:
assert e.args[0].code() in (KafkaError._TIMED_OUT, KafkaError._WAIT_COORD)
assert e.args[0].code() in (KafkaError._TIMED_OUT, KafkaError._NO_OFFSET)

# Get current position, should all be invalid.
kc.position(partitions)
Expand Down