Hey! Maybe I'm missing something, but why do you need to lock Kafka consumers? You can run multiple consumers within the same consumer group and get built-in high-availability (partition rebalancing when one consumer goes down)