Divij Vaidya

> @divijvaidya Sorry again for the long delay. By the way, I was wondering if we should also do this in the AbstractFetcherThread in order to close sessions used by...

> I uploaded a new version at https://github.com/apache/kafka/pull/12662 In that case, closing this one.

There is a previous PR open for this at https://github.com/apache/kafka/pull/14583 I have a comment there on possible usage of `spy`. Can you please explore that approach and let us know...

Note that this PR in it's current form leads to a large number of test failures. Please ensure that we fix the tests before marking it ready for review.

The build is failing because we need to modify a few other tests to use enum instead of string. Please tag me here again for review once we have a...

Hey @testn Tests in the CI seem to be failing due to this change such as https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-15403/6/testReport/junit/kafka.server/DynamicConfigChangeTest/Build___JDK_11_and_Scala_2_13___testMessageFormatVersionChange_String__quorum_zk/ You can verify them by running `./gradlew test` locally. Please check and fix...

Could you please help me understand how this change works with `fetch.max.wait.ms` from a user perspective i.e. what happens when we are retrieving data from both local & remote in...

Hi @Vaibhav-Nazare It was intentionally disabled in the past since the infrastructure was flaky https://github.com/apache/kafka/pull/12380 If we want to officially test and support this platform, I would suggest that you...

Hey @Vaibhav-Nazare The next step us to start a [DISCUSS] thread in the mailing list where the community can have a discussion on the KIP. The process of starting a...

Hey @Vaibhav-Nazare A KIP needs at least 3 committer votes and I believe we haven't heard from other folks in the community on the KIP. I am waiting for others...