This is an automated email from the ASF dual-hosted git repository.
lucasbru pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 5268fcdc984 KAFKA-18678 Update TestVerifiableProducer system test
(#18768)
add eb01221dc00 KAFKA-17125: Streams Sticky Task Assignor (#18652)
No new revisions were added by this update.
Summary of changes:
.../group/streams/assignor/ProcessState.java | 149 +++
.../group/streams/assignor/StickyTaskAssignor.java | 437 ++++++++
.../group/streams/assignor/TaskAssignor.java | 2 +
.../group/streams/assignor/ProcessStateTest.java | 124 +++
.../streams/assignor/StickyTaskAssignorTest.java | 1126 ++++++++++++++++++++
5 files changed, 1838 insertions(+)
create mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java
create mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java
create mode 100644
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessStateTest.java
create mode 100644
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignorTest.java
