[KafkaIO] Use consumer position and lag to estimate end offsets#39285

Abacn merged 2 commits into

apache:masterapache/beam:masterfrom

sjvanrossum:kafkaio-admin-offset-estimationsjvanrossum/beam:kafkaio-admin-offset-estimationCopy head branch name to clipboard