tree 1a4ec4d1ee5b9b5ebc22d9eb377a18c9658d19d2
parent 6b128d7e30cb654f26f11ae650465aa3caa38185
author Lianet Magrans <98415067+lianetm@users.noreply.github.com> 1686258225 -0400
committer GitHub <noreply@github.com> 1686258225 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJkgkIxCRBK7hj4Ov3rIwAAdSoIAIsJSHR4JIT7ElUfrF3yKrCI
 zORwoyjzOG31YGpJiOMTYrGZ15SvmLGZpEkUYov6hMCDaYcI5iFUvCj3BmbLWpLQ
 FOGHzjauszdqiEn3mvEcmGzuxolH6ix7Sbnw9eE5EgxZUyg5MYPZAdqw+Qj7sMRD
 itjUyShJDLFL/4yAijqWtdre5fE04fvou0XLk96vVVOHG1+f/jcgin85MZ7W/F3Y
 19GduUR69gXiT5A9vq+djqf9WZRT7JGqDecBnr3vpTlZtO+u7YfBfn5/P/Yp1C75
 ZZtVNd48uS182QwOIQHhsR1zmFBXJFTtLgvM5Qbb3OM83I4Q49hEL+p+w3j4EuY=
 =KxeJ
 -----END PGP SIGNATURE-----
 

KAFKA-14966:  Extract OffsetFetcher reusable logic (#13815)

The OffsetFetcher is internally used by the KafkaConsumer to fetch offsets, validate and reset positions. For the new KafkaConsumer with a refactored threading model, similar functionality will be needed.

This is an initial refactoring for extracting logic from the OffsetFetcher, that will be reused by the new consumer implementation. No changes to the existing logic, just extracting classes, functions or pieces of logic.

All the functionality moved out of the OffsetFetcher is already covered by tests in OffsetFetcherTest and FetcherTest. There were no individual tests for the extracted functions, so no tests were migrated.

Reviewers: Jun Rao <junrao@gmail.com>