mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1271148006
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation (
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1271147536
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,377 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1270057798
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/GraphTest.java:
##
@@ -0,0 +1,414 @@
+/*
+ * Licensed to the Apache Software Foundation (
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1265999671
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,367 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1262978439
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1262977617
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,348 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mjsax commented on code in PR #13996:
URL: https://github.com/apache/kafka/pull/13996#discussion_r1261835084
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java:
##
@@ -0,0 +1,363 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)