How to associate exactly one partition with one logstash consumer

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.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.