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
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
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
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
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:
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:
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
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
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
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
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:
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
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
13 matches
Mail list logo