GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/2895
KAFKA-5111: Improve internal Task APIs
Refactors Task with proper interface methods `init()`, `resume()`,
`commit()`, `suspend()`, and `close()`. All other methods for task handling are
internal now. This allows to simplify `StreamThread` code, avoid code
duplication and allows for easier reasoning of control flow.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka kafka-5111-cleanup-task-code
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2895.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 #2895
----
commit d2a4593e967ca4804291c50baece5c66f3469f59
Author: Matthias J. Sax <matth...@confluent.io>
Date: 2017-04-21T23:24:05Z
Code Cleanup
commit 27a4d7da6716bff235557ae0ada89abddfdc0f39
Author: Matthias J. Sax <matth...@confluent.io>
Date: 2017-04-22T02:05:45Z
KAFKA-5111: Improve internal Task APIs
commit 45bbc1714cccc98814b49b2dd30638e10f4eb317
Author: Matthias J. Sax <matth...@confluent.io>
Date: 2017-04-22T04:57:08Z
Post code cleanup
----
---
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.
---
