mirror of
https://github.com/apache/druid.git
synced 2025-02-10 03:55:02 +00:00
* Implement "earlyMessageRejectionPeriod" config discussed in issue #4599 * implement the logics of this param * Added doc of this config * Added unit tests of it * Update KafkaSupervisor.java ameliorate comment * fix format * fix bug when rebasing