pass kafka connection to KafKaQueue, make queue length always return
positive number
scheduler big fixes
scheduler cleanup