divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1561407539
Failing tests are unrelated:
```
Build / JDK 11 and Scala 2.13 / [1] quorum=kraft, isIdempotenceEnabled=true
– kafka.api.SaslPlainSslEndToEndAuthorizationTest
14s
Build /
divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1521852820
This is ready for review. A summary of the changes is provided below.
**On the server:**
1. This PR starts using buffer pools to allocate intermediate buffer which
is used
divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1497651824
Thank you @ijuma for your review. I will address the comments in next one
week since I am on vacation for next few days.
> Was this done?
Yes, consumer performance
divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1428471245
@ijuma I have updated this PR by extracting out an interface for the new
streams. Please take a look when you get a chance.
--
This is an automated message from the Apache Git
divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1400407941
TODO (will update PR in a short while) -
1. Add benchmark for case when batch contains single 10 byte message
2. Test consumer performance
--
This is an automated
divijvaidya commented on PR #13135:
URL: https://github.com/apache/kafka/pull/13135#issuecomment-1398428117
@ijuma please review when you get a chance since you already have context
about this code change.
--
This is an automated message from the Apache Git Service.
To respond to the
