@dstephens are you using exactly-once semantics? If so, the kafka console tools will report the lag as 1 even when all messages have been processed
ahh, yes I am. Thanks, I guess just something I need to be aware of then, cheers!