Implement the Single-Active Consumer feature. Java reference: https://rabbitmq.github.io/rabbitmq-stream-java-client/sac/htmlsingle/#single-active-consumer Single Active Consumer requires RabbitMQ 3.11 or more.