[KafkaIO] Extract expiring memoizing supplier as a separate utility and run end offset refreshes in the current thread#36075

jrmccluskey merged 3 commits intoapache:masterapache/beam:masterfrom

sjvanrossum:kafkaio-expiring-memoizing-serializable-suppliersjvanrossum/beam:kafkaio-expiring-memoizing-serializable-supplierCopy head branch name to clipboard