root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity
kafka/streams
History
John Roesler 5bb3415c77
KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) 
* add a config to set the TaskAssignor
* set the default assignor to HighAvailabilityTaskAssignor
* fix broken tests (with some TODOs in the system tests)

Implements: KIP-441
Reviewers: Bruno Cadonna <bruno@confluent.io>, A. Sophie Blee-Goldman <sophie@confluent.io>
 		2020-04-28 15:57:11 -05:00
..
examples/src KAFKA-8410: Part 1: processor context bounds (#8414) 2020-04-07 13:11:02 -05:00
quickstart
…
src KAFKA-6145: KIP-441: Add TaskAssignor class config (#8541) 2020-04-28 15:57:11 -05:00
streams-scala KAFKA-8410: Part 1: processor context bounds (#8414) 2020-04-07 13:11:02 -05:00
test-utils/src KAFKA-8410: Part 1: processor context bounds (#8414) 2020-04-07 13:11:02 -05:00
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests KAFKA-9779: Add Stream system test for 2.5 release (#8378) 2020-04-15 15:59:03 -07:00
.gitignore
…