[KafkaIO] Determine partition backlog using endOffsets instead of seek2End and position#32889

Merged

johnjcasey merged 4 commits intoapache:masterfrom

sjvanrossum:kafkaio-endoffsets

Nov 6, 2024

Commits on Oct 24, 2024

Commits on Oct 25, 2024

Explicitly update partitions and start/end offsets for relevant mock consumers
sjvanrossum
committed

Commits on Oct 31, 2024

Clean up partition and offset updates in tests
sjvanrossum
committed