I have a kafka producer which is producing messages for two topics and for each topic I have allocated 4 partitions.
I have allocated 8 consumer threads for the above two topics and hence assume that each consumer thread will serve each partition.
I there a way to strictly enforce this above policy.