Отставание группы консьюмеров по партициям

Напишите consumer_lag(end_offsets, committed).

• end_offsets — словарь партиция → смещение следующего сообщения, которое будет записано.
• committed — словарь партиция → закоммиченное смещение группы. Партиции может не быть: группа её ещё не читала, тогда lag равен end_offsets целиком (чтение с начала, смещение 0).
• Верните кортеж (total, worst): суммарный lag и номер партиции с наибольшим lag. При равенстве — меньший номер партиции. Если все lag нулевые или партиций нет, worst равен None.

def consumer_lag(end_offsets, committed):
    # ваш код
    return None