Justin Borromeo 2771ed50b0 Support Kafka supervisor adopting running tasks between versions (#7212) ... * Recompute hash in isTaskCurrent() and added tests * Fixed checkstyle stuff * Fixed failing tests * Make TestableKafkaSupervisorWithCustomIsTaskCurrent static * Add doc * baseSequenceName change * Added comment * WIP * Fixed imports * Undid lambda change for diff sake * Cleanup * Added comment * Reinsert Kafka tests * Readded kinesis test * Readd bad partition assignment in kinesis supervisor test * Nit * Misnamed var		2019-04-10 18:16:38 -07:00
..
src	Support Kafka supervisor adopting running tasks between versions (#7212)	2019-04-10 18:16:38 -07:00
pom.xml	Move GCP to a core extension (#6953)	2019-03-27 09:00:43 -07:00