Предположим, у меня есть потребитель, подписанный на несколько тем. Какая тема выбрана, когда я делаю опрос? Я использую RdKafka .Net для клиента. Есть ли способ повлиять, какая тема выбрана?Как потребитель Кафки выбирает, из какой темы в следующий опрос?
Потребитель делает опрос для всех разделов раздела (которые не приостановлены). Брокер решает, какие данные нужно вернуть. Вы не можете напрямую влиять на поведение брокера.
Не уверен, что RdKafka имеет API для приостановки и возобновления разделов. Я только сейчас Java KafkaConsumer, который предлагает методы #pause() и #resume().