Hi, I have one topic with 300 partitions. I have 4 KSQL instances with 8 threads each on 8 core machine. Topic has lag of around million records. Can I increase number of threads equal to number of partitions so hat lag will be reduced? Or I have to reduce partitions to match total number of threads?
please advise how do I reduce lag on source topic. Thanks
