How to be with a consumer group when reading a single topic in multithreading?