Luke Chen
Luke Chen
> Perhaps a naive question but does the fetch request to close the session fetches any records? Or does it just close the session and return? @dajac , good question....
@divijvaidya , you're right, thanks for the update! Sorry, I only checked the broker side implementation that although we created `SessionlessFetchContext`, it still return the fetched records. I missed the...
I can't see where's the difference between `synchronized` and `inLock`, either. Could you please explain more?
@rhauch , per our discussion, here's the tests to be added. Thank you.
Failed tests are unrelated. Thank you. ``` Build / JDK 17 and Scala 2.13 / kafka.admin.LeaderElectionCommandTest.[1] Type=Raft, Name=testTopicPartition, Security=PLAINTEXT Build / JDK 17 and Scala 2.13 / kafka.admin.LeaderElectionCommandTest.[1] Type=Raft, Name=testTopicPartition,...
@mimaison @rajinisivaram , please take a look. Thanks.
@dajac, thanks for the comment. Yes, I agree with you that this could result in flooding the logs in highly loaded system. But still, if the client got blocked due...
@apurvam @hachikuji , could you review this PR? Thanks.
@apurvam @hachikuji , could you review this PR? Thanks.
@apurvam @hachikuji , call for review. Thank you.