GitHub user enothereska opened a pull request:
https://github.com/apache/kafka/pull/290
KAFKA-2459: connection backoff, timeouts and retries
This fix applies to three JIRAs, since they are all connected.
KAFKA-2459Connection backoff/blackout period should start when a connection
is disconnected, not when the connection attempt was initiated
Backoff when connection is disconnected
KAFKA-2615Poll() method is broken wrt time
Added Time through the NetworkClient API. Minimal change.
KAFKA-1843Metadata fetch/refresh in new producer should handle all node
connection states gracefully
Iâve partially addressed this for a specific failure case in the JIRA.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/enothereska/kafka trunk
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/290.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 #290
----
commit 90c0085a76374fafe6fa62c18e3d24504852e687
Author: Eno Thereska <[email protected]>
Date: 2015-10-07T00:06:49Z
Commits to fix timing issues in three JIRAs
commit ee66491fb36d55527d156afda90c3addc3eb3175
Author: Eno Thereska <[email protected]>
Date: 2015-10-07T00:07:21Z
Merge remote-tracking branch 'apache-kafka/trunk' into trunk
commit 17a373733e414456475217248cbc7b0bc98fda40
Author: Eno Thereska <[email protected]>
Date: 2015-10-07T15:15:19Z
Merge remote-tracking branch 'apache-kafka/trunk' into trunk
commit eb5fbf458a5b455ae8b3c8b3ebf32524f5a3ab3e
Author: Eno Thereska <[email protected]>
Date: 2015-10-07T16:20:45Z
Removed debug messages
commit 041baae45012cf8f99afd2c8b5d9a8099a8a928b
Author: Eno Thereska <[email protected]>
Date: 2015-10-07T17:35:12Z
Pick a node, but not one that is blacked out
commit 69679d7e61d36f76d2ea1dd1fcc0a1192c9b50d6
Author: Eno Thereska <[email protected]>
Date: 2015-10-08T17:18:02Z
Removed unneeded checks
commit 3ce5e151396575f45d1f022720f454ac36653d0d
Author: Eno Thereska <[email protected]>
Date: 2015-10-08T17:18:18Z
Merge remote-tracking branch 'apache-kafka/trunk' into trunk
commit 76e6a0d8ab3fe847b28edde2e0072e7fe06484ff
Author: Eno Thereska <[email protected]>
Date: 2015-10-08T23:35:41Z
More efficient implementation of nodesEverSeen
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
