Kafka представила новый потребительский API-интерфейс высокого уровня, а старый SimpleConsumer устарел.Однако в документах отсутствует информация о гарантиях локальности данных.С SimpleConsumer было очевидно, что данные читаются только одним брокером.
А как насчет нового API?Например, если у меня есть 2 сервера с брокером и потребителем на каждом, есть ли способ принудительного чтения локальных данных?Или каждый потребитель будет читать от случайного брокера?