You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/05/27 18:50:57 UTC

[kafka] branch trunk updated (075bbcf -> 2cff1fa)

This is an automated email from the ASF dual-hosted git repository.

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


    from 075bbcf  KAFKA-7523: Add ConnectedStoreProvider to Processor API (#6824)
     add 2cff1fa  KAFKA-6145: KIP-441: Fix assignor config passthough (#8716)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/common/utils/Utils.java  |  14 +++
 .../org/apache/kafka/streams/StreamsConfig.java    |   5 +-
 .../assignment/AssignorConfiguration.java          |  30 +++--
 .../internals/assignment/ClientState.java          |   1 +
 .../assignment/HighAvailabilityTaskAssignor.java   |  28 +++--
 .../internals/assignment/TaskMovement.java         |  17 +--
 .../apache/kafka/streams/StreamsConfigTest.java    |   6 +
 .../integration/TaskAssignorIntegrationTest.java   | 138 +++++++++++++++++++++
 .../assignment/AssignorConfigurationTest.java      |  27 ++--
 .../assignment/FallbackPriorTaskAssignorTest.java  |   2 +-
 .../HighAvailabilityTaskAssignorTest.java          |  51 ++++----
 .../assignment/StickyTaskAssignorTest.java         |   4 +-
 .../assignment/TaskAssignorConvergenceTest.java    |   8 +-
 .../internals/assignment/TaskMovementTest.java     |  12 +-
 tests/kafkatest/services/streams.py                |   6 +
 15 files changed, 271 insertions(+), 78 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/TaskAssignorIntegrationTest.java
 copy connect/transforms/src/test/java/org/apache/kafka/connect/transforms/util/NonEmptyListValidatorTest.java => streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfigurationTest.java (59%)