Tejaswini Bandlamudi
|
3e13584e0e
|
Adds Idle feature to `SeekableStreamSupervisor` for inactive stream (#13144)
* Idle Seekable stream supervisor changes.
* nit
* nit
* nit
* Adds unit tests
* Supervisor decides it's idle state instead of AutoScaler
* docs update
* nit
* nit
* docs update
* Adds Kafka unit test
* Adds Kafka Integration test.
* Updates travis config.
* Updates kafka-indexing-service dependencies.
* updates previous offsets snapshot & doc
* Doesn't act if supervisor is suspended.
* Fixes highest current offsets fetch bug, adds new Kafka UT tests, doc changes.
* Reverts Kinesis Supervisor idle behaviour changes.
* nit
* nit
* Corrects SeekableStreamSupervisorSpec check on idle behaviour config, adds tests.
* Fixes getHighestCurrentOffsets to fetch offsets of publishing tasks too
* Adds Kafka Supervisor UT
* Improves test coverage in druid-server
* Corrects IT override config
* Doc updates and Syntactic changes
* nit
* supervisorSpec.ioConfig.idleConfig changes
|
2022-10-12 18:31:08 +05:30 |