Мы используем версию Kafka 0.9, и большое количество сообщений отправляется в определенный раздел в теме kafka. И таких разделов в этой теме несколько. У нас есть один потребитель, назначенный на раздел в рамках этой темы, и мы поддерживаем смещение вручную в разделе темы во внешнем хранилище данных. Я хотел знать, если мы начнем получать действительно большое количество сообщений в разделе темы, возможно ли, чтобы потребитель имел дело с разделом темы, чтобы быть многопоточным. Потому что может оказаться невозможным, чтобы экземпляр потребителя, назначенный разделу, смог завершить обработку всех записей за желаемый промежуток времени. Возможен ли такой многопоточный потребитель с перегородкой? Это рекомендуется? Также, если ответ ДА, то как несколько потоков могут управлять смещением, потому что все эти потоки имеют дело с сообщениями в одном разделе. Доступен какой-нибудь образец фрагмента?
Обратите внимание: я спрашиваю о «потребителе, имеющем дело с одним разделом внутри темы», я не смотрю на группу потребителей для темы, разделенной на разделы в ней.
