kafka git commit: KAFKA-5147; Add missing synchronization to TransactionManager

2017-05-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/0.11.0 7dde914aa -> c62793eab KAFKA-5147; Add missing synchronization to TransactionManager The basic idea is that exactly three collections, ie. `pendingRequests`, `newPartitionsToBeAddedToTransaction`, and `partitionsInTransaction` are

kafka git commit: KAFKA-5147; Add missing synchronization to TransactionManager

2017-05-25 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 73ca0d215 -> 02c0c3b01 KAFKA-5147; Add missing synchronization to TransactionManager The basic idea is that exactly three collections, ie. `pendingRequests`, `newPartitionsToBeAddedToTransaction`, and `partitionsInTransaction` are

kafka git commit: KAFKA-5320: Include all request throttling in client throttle metrics

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 a7bd4b3aa -> 7dde914aa KAFKA-5320: Include all request throttling in client throttle metrics Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #3137 from

kafka git commit: KAFKA-5320: Include all request throttling in client throttle metrics

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk 20e200878 -> 73ca0d215 KAFKA-5320: Include all request throttling in client throttle metrics Author: Rajini Sivaram Reviewers: Jun Rao , Ismael Juma Closes #3137 from

kafka git commit: KAFKA-5279: TransactionCoordinator must expire transactionalIds

2017-05-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/0.11.0 c3f806d02 -> a7bd4b3aa KAFKA-5279: TransactionCoordinator must expire transactionalIds remove transactions that have not been updated for at least `transactional.id.expiration.ms` Author: Damian Guy Reviewers:

kafka git commit: KAFKA-5279: TransactionCoordinator must expire transactionalIds

2017-05-25 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 64fc1a7ca -> 20e200878 KAFKA-5279: TransactionCoordinator must expire transactionalIds remove transactions that have not been updated for at least `transactional.id.expiration.ms` Author: Damian Guy Reviewers:

kafka git commit: KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/0.11.0 22288e805 -> c3f806d02 KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes For consumers with manual partition assignment, await metadata when there are no ready nodes to avoid busy polling. Author: Rajini Sivaram

kafka git commit: KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes

2017-05-25 Thread rsivaram
Repository: kafka Updated Branches: refs/heads/trunk a10990f44 -> 64fc1a7ca KAFKA-5263: Avoid tight polling loop in consumer with no ready nodes For consumers with manual partition assignment, await metadata when there are no ready nodes to avoid busy polling. Author: Rajini Sivaram

kafka git commit: MINOR: fix flakiness in testDeleteAcls

2017-05-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 6ed7288fd -> 22288e805 MINOR: fix flakiness in testDeleteAcls This call to isCompletedExceptionally introduced a race condition because the future might not have been completed. assertFutureError checks that the exception is present and

kafka git commit: MINOR: fix flakiness in testDeleteAcls

2017-05-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk cea319a4a -> a10990f44 MINOR: fix flakiness in testDeleteAcls This call to isCompletedExceptionally introduced a race condition because the future might not have been completed. assertFutureError checks that the exception is present and of

[2/2] kafka git commit: KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2

2017-05-25 Thread ijuma
KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2 Author: Jason Gustafson Reviewers: Apurva Mehta , Ismael Juma Closes #3123 from hachikuji/KAFKA-4935 Project:

[1/2] kafka git commit: KAFKA-4208; Add record headers upgrade doc

2017-05-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/0.11.0 8dfc098ee -> 6ed7288fd KAFKA-4208; Add record headers upgrade doc Update upgrade.html Raising this now, as KIP-118 is pulled from release as such submitting this without java 8 changes. As per remaining review comment from

kafka git commit: KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2

2017-05-25 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk fdcee8b8b -> cea319a4a KAFKA-4935; Deprecate client checksum API and compute lazy partial checksum for magic v2 Author: Jason Gustafson Reviewers: Apurva Mehta , Ismael Juma