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

Show file tree
Hide file tree
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
Minor cleanups
  • Loading branch information
@edenhill
edenhill committed May 9, 2016
commit ee588bf4153a8ef90ac9a24c38495aac1839f0d2
7 changes: 7 additions & 0 deletions confluent_kafka/kafkatest/README
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1,8 @@
FIXME: Instructions on how to use this.


Usage:

python -m confluent_kafka.kafkatest.verifiable_consumer <options>

python -m confluent_kafka.kafkatest.verifiable_producer <options>
2 changes: 1 addition & 1 deletion confluent_kafka/kafkatest/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1 +1 @@
""" This directory contains clients implementing the official Kafka tests/kafkatest."""
""" Python client implementations of the official Kafka tests/kafkatest clients. """
3 changes: 0 additions & 3 deletions docs/index.rst
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,3 @@ The Python bindings also provide some additional configuration properties:

* ``on_commit`` (**Consumer**): Callback used to indicate success or failure
of commit requests.