Repository: kafka
Updated Branches:
refs/heads/0.10.2 588c5667f -> 7bb1d2a44
MINOR: fixed some JavaDoc typos
Author: Matthias J. Sax
Reviewers: Ewen Cheslack-Postava
Closes #2497 from mjsax/hofixJavaDocs0102
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wi
Repository: kafka
Updated Branches:
refs/heads/trunk 2c0055e62 -> 45d9fb3d5
KAFKA-4735; Fix deadlock issue during MM shutdown
In https://issues.apache.org/jira/browse/KAFKA-4521 we fixed a potential
message reorder bug in MM. However, the patch introduced another bug that can
cause deadlock
Repository: kafka
Updated Branches:
refs/heads/trunk 82e75b960 -> 2c0055e62
HOTFIX: Do Not use unlimited num messages in IntegrationTestUtils
Removed readKeyValues() that give UNLIMITED_MESSAGES which will doom to exhaust
all wait time, as all its callers actually do provide the expected numb
Repository: kafka
Updated Branches:
refs/heads/0.10.2 13a09557a -> 588c5667f
MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH
constant
Author: Ewen Cheslack-Postava
Reviewers: Matthias J. Sax , Guozhang Wang
Closes #2508 from ewencp/minor-streams-compatibilit
Repository: kafka
Updated Branches:
refs/heads/trunk 48aec6ef1 -> 82e75b960
MINOR: Fix import for streams broker compatibility test to use new DEV_BRANCH
constant
Author: Ewen Cheslack-Postava
Reviewers: Matthias J. Sax , Guozhang Wang
Closes #2508 from ewencp/minor-streams-compatibility
Repository: kafka
Updated Branches:
refs/heads/0.10.2 f4276b7cf -> 13a09557a
KAFKA-4441; Monitoring incorrect during topic creation and deletion
OfflinePartitionsCount PreferredReplicaImbalanceCount metrics check for
topic being deleted
Added integration test which polls the metrics while top
Repository: kafka
Updated Branches:
refs/heads/trunk b31a7a902 -> 48aec6ef1
KAFKA-4441; Monitoring incorrect during topic creation and deletion
OfflinePartitionsCount PreferredReplicaImbalanceCount metrics check for
topic being deleted
Added integration test which polls the metrics while topi
Repository: kafka
Updated Branches:
refs/heads/0.10.2 e321cd4f5 -> f4276b7cf
KAFKA-4728; KafkaConsumer#commitSync should copy its input
Author: Jan Lukavsky
Reviewers: Jason Gustafson
Closes #2491 from je-ik/KAFKA-4728
(cherry picked from commit b31a7a9022bfb645cb61e6fbc0b22829108b3a3f)
S
Repository: kafka
Updated Branches:
refs/heads/trunk 1f8a2ad2e -> b31a7a902
KAFKA-4728; KafkaConsumer#commitSync should copy its input
Author: Jan Lukavsky
Reviewers: Jason Gustafson
Closes #2491 from je-ik/KAFKA-4728
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: htt
Repository: kafka
Updated Branches:
refs/heads/trunk 7de22453b -> 1f8a2ad2e
KAFKA-4461: Added support to ProcessorTopologyTestDriver for internal topics
This resolves an issue in driving tests using the ProcessorTopologyTestDriver
when `groupBy()` is invoked downstream of a processor that fla
Repository: kafka
Updated Branches:
refs/heads/trunk d0932b028 -> 7de22453b
KAFKA-4724: Clean up of state directories can possibly remove stores that are
about to be used by another thread
Delay the cleanup of state directories that are not locked and not owned by the
current thread such tha
11 matches
Mail list logo