kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kkaranta...@apache.org
Subject [kafka] branch trunk updated (58794d2 -> 09b22e7)
Date Tue, 09 Jun 2020 16:41:52 GMT
This is an automated email from the ASF dual-hosted git repository.

kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 58794d2  MINOR: fix incorrect GC log size with JDK9+ (#8800)
     add 09b22e7  KAFKA-9848: Avoid triggering scheduled rebalance delay when task assignment
fails but Connect workers remain in the group (#8805)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   2 +-
 .../consumer/internals/AbstractCoordinator.java    |   2 +-
 .../runtime/distributed/DistributedConfig.java     |   2 +-
 .../IncrementalCooperativeAssignor.java            |  38 +++-
 .../runtime/distributed/WorkerCoordinator.java     |  13 ++
 .../integration/ConnectIntegrationTestUtils.java   |  27 ++-
 .../integration/ConnectWorkerIntegrationTest.java  |   5 +
 .../integration/ExampleConnectIntegrationTest.java |   5 +
 .../RebalanceSourceConnectorsIntegrationTest.java  |  13 +-
 .../IncrementalCooperativeAssignorTest.java        | 227 ++++++++++++++++-----
 10 files changed, 256 insertions(+), 78 deletions(-)
 copy streams/src/test/java/org/apache/kafka/test/MockValueJoiner.java => connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectIntegrationTestUtils.java
(54%)


Mime
View raw message