GitHub user Ishiihara opened a pull request:
https://github.com/apache/kafka/pull/279
Transient exception
Transient exception handling.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/confluentinc/kafka transient-exception
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/279.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #279
----
commit c97df6dc18f7068866132a9237e8242286bab7c1
Author: Ewen Cheslack-Postava <m...@ewencp.org>
Date: 2015-09-28T00:59:30Z
KAFKA-2482: Allow sink tasks to get their current assignment, as well as
pause and resume topic partitions.
commit 569d7b8ee2469f9427e002076d9e9b5af64aaf3b
Author: Ewen Cheslack-Postava <m...@ewencp.org>
Date: 2015-09-28T17:42:47Z
Merge branch 'trunk' of http://git-wip-us.apache.org/repos/asf/kafka into
kafka-2482-sink-tasks-pause-consumption
commit 1451a2f2a00072c849ba4309952f0e0132a65d89
Author: Liquan Pei <liquan...@gmail.com>
Date: 2015-10-01T22:20:33Z
Merge branch 'kafka-2482-sink-tasks-pause-consumption' of
https://github.com/ewencp/kafka into periodic-put
commit 68b87011ae77126aa116bb74e4bc0cf90549219b
Author: Liquan Pei <liquan...@gmail.com>
Date: 2015-10-05T21:40:33Z
Add transient exception handling
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
