Я использую SimpleConsumer и пытаюсь получить размер сообщения (в байтах), используя искру.
Я могу получить самое раннее и самое последнее смещение, используя запрос метаданных, но не знаю, как получить количество байтов в kafka (0.8.0).
Я действительно не хочу использовать запрос на выборку, потому что хочу проверить достаточно данных, а затем запустит задание искры (не потоковое) для выполнения действия.
