showuon commented on PR #13312:
URL: https://github.com/apache/kafka/pull/13312#issuecomment-1536156206
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.clients.consumer.internals.AbstractCoordinatorTest.testBackoffAndRetryUponRetriableError()
divijvaidya commented on PR #13623:
URL: https://github.com/apache/kafka/pull/13623#issuecomment-1536155781
Thank you @dajac. Appreciate your time and patience on this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719865#comment-17719865
]
Ismael Juma commented on KAFKA-14969:
-
I thought we should go straight to 5.x when we drop support
vvcephei commented on PR #13633:
URL: https://github.com/apache/kafka/pull/13633#issuecomment-1536478379
Actually, @mjsax , I do have one question before merging: Are there classes
that are meant to be overridden by users? If so, should their protected members
be documented?
--
This is
divijvaidya commented on code in PR #13673:
URL: https://github.com/apache/kafka/pull/13673#discussion_r1185999578
##
gradle/dependencies.gradle:
##
@@ -142,7 +142,7 @@ libs += [
apachedsMavibotPartition:
divijvaidya commented on code in PR #13673:
URL: https://github.com/apache/kafka/pull/13673#discussion_r1185999578
##
gradle/dependencies.gradle:
##
@@ -142,7 +142,7 @@ libs += [
apachedsMavibotPartition:
[
https://issues.apache.org/jira/browse/KAFKA-14926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-14926.
-
Resolution: Fixed
> Remove metrics on Log Cleaner shutdown
>
divijvaidya commented on PR #13312:
URL: https://github.com/apache/kafka/pull/13312#issuecomment-1536165039
Thank you @showuon and @ijuma for your time and patience in this review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
clayburn commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1186205824
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
showuon merged PR #13312:
URL: https://github.com/apache/kafka/pull/13312
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
Hendrik Jan van Randen created KAFKA-14968:
--
Summary: Consumer Notification Callback
Key: KAFKA-14968
URL: https://issues.apache.org/jira/browse/KAFKA-14968
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719886#comment-17719886
]
Mickael Maison commented on KAFKA-14698:
[~akhileshchg]/[~mumrah] What's the status of this
vvcephei commented on code in PR #13633:
URL: https://github.com/apache/kafka/pull/13633#discussion_r1186269574
##
build.gradle:
##
@@ -2057,6 +2057,7 @@ project(':streams') {
srcJar.dependsOn 'processMessages'
javadoc {
+options.memberLevel =
showuon commented on PR #13660:
URL: https://github.com/apache/kafka/pull/13660#issuecomment-1536155265
Retriggering the CI build since it failed with infra's issue.
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13660/3/
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/KAFKA-14805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719878#comment-17719878
]
Mickael Maison commented on KAFKA-14805:
[~mumrah] The associated PR is merged, is this work
[
https://issues.apache.org/jira/browse/KAFKA-14859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-14859.
---
Resolution: Fixed
Merged into trunk and 3.5
> Support SCRAM ZK to KRaft Migration
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719922#comment-17719922
]
Mickael Maison commented on KAFKA-14084:
So I think we could close this ticket, as effectively
rohits64 opened a new pull request, #13677:
URL: https://github.com/apache/kafka/pull/13677
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
chia7712 commented on PR #13659:
URL: https://github.com/apache/kafka/pull/13659#issuecomment-1536128806
failed tests are unrelated. Will merge it later
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
[
https://issues.apache.org/jira/browse/KAFKA-14918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719880#comment-17719880
]
Mickael Maison commented on KAFKA-14918:
Ping [~mumrah] can you share an update? Otherwise I'll
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719885#comment-17719885
]
Mickael Maison commented on KAFKA-14831:
Is this near completion? If not I'll move this out of
clayburn commented on PR #13676:
URL: https://github.com/apache/kafka/pull/13676#issuecomment-1536412348
> Thank you for the contribution.
>
> It would be super helpful (perhaps outside of this PR) if you could add a
section in our documentation [1] on how to monitor the result of
rohits64 commented on PR #13677:
URL: https://github.com/apache/kafka/pull/13677#issuecomment-1536165839
Duplicate
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
rohits64 closed pull request #13677: KAFKA-14401 with test [WIP]
URL: https://github.com/apache/kafka/pull/13677
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
Divij Vaidya created KAFKA-14969:
Summary: Upgrade Mockito to 4.11.0
Key: KAFKA-14969
URL: https://issues.apache.org/jira/browse/KAFKA-14969
Project: Kafka
Issue Type: Improvement
lucasbru commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1186098795
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map> activeTasks,
[
https://issues.apache.org/jira/browse/KAFKA-14901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719868#comment-17719868
]
Mickael Maison commented on KAFKA-14901:
[~gharris1727] Do you think this is a blocker for 3.5?
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719899#comment-17719899
]
Proven Provenzano commented on KAFKA-14084:
---
[~mimaison] The last commit for SCRAM migration
clayburn commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1186202287
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
showuon commented on PR #13515:
URL: https://github.com/apache/kafka/pull/13515#issuecomment-1536153857
Retriggering the CI build since it failed with some infra's issue.
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-13515/8/
--
This is an automated message from the Apache
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen reassigned KAFKA-14968:
--
Assignee: Hendrik Jan van Randen
> Consumer Notification Callback
>
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen updated KAFKA-14968:
---
Description:
We want to use Kafka for all the communication between our
divijvaidya commented on PR #13670:
URL: https://github.com/apache/kafka/pull/13670#issuecomment-1536300068
The failing tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
testElectUncleanLeadersForOnePartition(String).quorum=kraft –
kafka.api.PlaintextAdminIntegrationTest
26s
[
https://issues.apache.org/jira/browse/KAFKA-14840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719881#comment-17719881
]
Mickael Maison commented on KAFKA-14840:
[~mumrah] The associated PR is merged, is this now
dajac merged PR #13623:
URL: https://github.com/apache/kafka/pull/13623
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719877#comment-17719877
]
Mickael Maison commented on KAFKA-14084:
[~cmccabe]/[~pprovenzano] What is the status of this?
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Reviewer: Justine Olshan
> Illegal state errors should be fatal in transactional producer
>
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Description: In KAFKA-14830, the producer hit an illegal state error. The
error was propagated to the
[
https://issues.apache.org/jira/browse/KAFKA-14961?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719933#comment-17719933
]
Kirk True commented on KAFKA-14961:
---
cc [~pnee] [~lianetm]
>
wenbingshen closed pull request #10625: MINOR: Fix error log for bounce broker
URL: https://github.com/apache/kafka/pull/10625
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
wenbingshen opened a new pull request, #10625:
URL: https://github.com/apache/kafka/pull/10625
bounce leader broker for topic partition was mistakenly log as a follower
broker
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ]
[
https://issues.apache.org/jira/browse/KAFKA-14968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hendrik Jan van Randen updated KAFKA-14968:
---
Description:
We want to use Kafka for all the communication between our
jolshan commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1536545551
https://github.com/apache/kafka/commit/ea81e99e5980c807414651034a8c60426a158ca4
added TransitionToUnitialized. Can we confirm this has the behavior we expect?
I believe this would count
mjsax commented on PR #13633:
URL: https://github.com/apache/kafka/pull/13633#issuecomment-1536581114
Thank @vvcephei -- for K14839 in particular, it's nothing users should
overwrite, in fact, they should not even extend the class in question at all.
I did not double check in general
chia7712 merged PR #13659:
URL: https://github.com/apache/kafka/pull/13659
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-14084.
---
Resolution: Fixed
SCRAM support in KRaft is implemented.
Test of SCRAM
junrao commented on code in PR #13503:
URL: https://github.com/apache/kafka/pull/13503#discussion_r1186548617
##
core/src/test/scala/unit/kafka/server/ReplicaFetcherTierStateMachineTest.scala:
##
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
mjsax commented on code in PR #13633:
URL: https://github.com/apache/kafka/pull/13633#discussion_r1186357597
##
build.gradle:
##
@@ -2057,6 +2057,7 @@ project(':streams') {
srcJar.dependsOn 'processMessages'
javadoc {
+options.memberLevel = JavadocMemberLevel.PUBLIC
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719988#comment-17719988
]
Kirk True commented on KAFKA-14831:
---
Sounds good, [~jolshan]. I updated the fix version to 3.6.0.
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14831:
--
Fix Version/s: 3.6.0
(was: 3.5.0)
> Illegal state errors should be fatal in
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719992#comment-17719992
]
Mickael Maison commented on KAFKA-14831:
Thanks!
> Illegal state errors should be fatal in
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719931#comment-17719931
]
Kirk True commented on KAFKA-14831:
---
[~jolshan] has been providing most of the feedback on the PR.
vvcephei commented on PR #13455:
URL: https://github.com/apache/kafka/pull/13455#issuecomment-1536829632
There were a lot of test failures. I just triggered it again.
It doesn't seem implausible that changing the MockConsumer could cause other
tests to fail, but I didn't look at
[
https://issues.apache.org/jira/browse/KAFKA-14791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Grant reassigned KAFKA-14791:
Assignee: Andrew Grant
> Create a builder class for PartitionRegistration
>
Proven Provenzano created KAFKA-14970:
-
Summary: Dual write mode testing for SCRAM and Quota
Key: KAFKA-14970
URL: https://issues.apache.org/jira/browse/KAFKA-14970
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719993#comment-17719993
]
Mickael Maison commented on KAFKA-14084:
Thanks!
> Support SCRAM when using KRaft mode
>
vvcephei commented on PR #13664:
URL: https://github.com/apache/kafka/pull/13664#issuecomment-1536827381
I'm re-running the tests to see if we can get a green build.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
jolshan commented on code in PR #13638:
URL: https://github.com/apache/kafka/pull/13638#discussion_r1186307624
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilder.java:
##
@@ -0,0 +1,445 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-14831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719941#comment-17719941
]
Justine Olshan commented on KAFKA-14831:
I guess I had assumed we missed the code freeze and
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185968862
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -262,6 +262,42 @@ private void closeDirtyAndRevive(final Collection
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185970601
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map>
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185973531
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map>
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185974966
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map>
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185975845
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,18 @@ public void handleAssignment(final Map>
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185979279
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,18 @@ public void handleAssignment(final Map>
vamossagar12 commented on code in PR #11433:
URL: https://github.com/apache/kafka/pull/11433#discussion_r1185978385
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -342,7 +342,19 @@ public void handleAssignment(final Map>
fvaleri commented on code in PR #13515:
URL: https://github.com/apache/kafka/pull/13515#discussion_r1185727238
##
examples/src/main/java/kafka/examples/Producer.java:
##
@@ -21,133 +21,164 @@
import org.apache.kafka.clients.producer.ProducerConfig;
import
fvaleri commented on code in PR #13515:
URL: https://github.com/apache/kafka/pull/13515#discussion_r1185727238
##
examples/src/main/java/kafka/examples/Producer.java:
##
@@ -21,133 +21,164 @@
import org.apache.kafka.clients.producer.ProducerConfig;
import
showuon commented on code in PR #13515:
URL: https://github.com/apache/kafka/pull/13515#discussion_r1185732188
##
examples/src/main/java/kafka/examples/Producer.java:
##
@@ -21,133 +21,164 @@
import org.apache.kafka.clients.producer.ProducerConfig;
import
dajac commented on code in PR #13638:
URL: https://github.com/apache/kafka/pull/13638#discussion_r1185749017
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilderTest.java:
##
@@ -0,0 +1,558 @@
+/*
+ * Licensed to the Apache
fvaleri commented on code in PR #13515:
URL: https://github.com/apache/kafka/pull/13515#discussion_r1185727238
##
examples/src/main/java/kafka/examples/Producer.java:
##
@@ -21,133 +21,164 @@
import org.apache.kafka.clients.producer.ProducerConfig;
import
dajac commented on code in PR #13638:
URL: https://github.com/apache/kafka/pull/13638#discussion_r1185752497
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/consumer/CurrentAssignmentBuilderTest.java:
##
@@ -0,0 +1,558 @@
+/*
+ * Licensed to the Apache
cmccabe merged PR #13461:
URL: https://github.com/apache/kafka/pull/13461
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail:
cmccabe commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1535924639
> @Hangleton : Agree that this change should be ideally confined to the
Windows platform w/o any code change for others.
Yeah. To be totally clear, it's OK to change the main code
bmscomp commented on PR #13662:
URL: https://github.com/apache/kafka/pull/13662#issuecomment-1535937778
@divijvaidya I get your point, thanks so much for those explanations
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
urbandan commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1185797643
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -424,6 +477,11 @@ ProducerIdAndEpoch producerIdAndEpoch() {
}
clolov commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1185861417
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -2707,11 +2742,271 @@ public void
divijvaidya commented on code in PR #13676:
URL: https://github.com/apache/kafka/pull/13676#discussion_r1185859941
##
settings.gradle:
##
@@ -13,6 +13,38 @@
// See the License for the specific language governing permissions and
// limitations under the License.
+plugins {
+
huxiangquan commented on PR #12331:
URL: https://github.com/apache/kafka/pull/12331#issuecomment-1536010891
Can someone help kafka on windows , please?
Two years have passed ！
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
[
https://issues.apache.org/jira/browse/KAFKA-14805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14805:
--
Fix Version/s: (was: 3.4.1)
> KRaft Controller shouldn't allow metadata updates before migration
[
https://issues.apache.org/jira/browse/KAFKA-14963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-14963.
---
Resolution: Fixed
> Incorrect partition count metrics for kraft controllers
>
divijvaidya commented on PR #13662:
URL: https://github.com/apache/kafka/pull/13662#issuecomment-1535880466
@bmscomp this is a nice PR and I support it. I opened the other one (
https://github.com/apache/kafka/pull/13673 ) for minor versions upgrades
because minor versions have a lower
divijvaidya commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1535884087
@hudeqi thanks for reminding me about this. I will review it next week.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-14514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14514:
---
Assignee: David Jacot
> Implement range broker side assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-14515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14515:
---
Assignee: David Jacot
> Implement uniform broker side assignor
>
[
https://issues.apache.org/jira/browse/KAFKA-14501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14501:
---
Assignee: Jeff Kim
> Implement Heartbeat API
> ---
>
>
Hangleton commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1185779424
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinatorTest.java:
##
@@ -2707,11 +2742,271 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-14502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-14502:
---
Assignee: Jeff Kim
> Implement LeaveGroup API
>
>
>
divijvaidya commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1185820116
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
divijvaidya commented on code in PR #13312:
URL: https://github.com/apache/kafka/pull/13312#discussion_r1185820299
##
clients/src/test/java/org/apache/kafka/common/utils/ByteUtilsTest.java:
##
@@ -241,6 +244,119 @@ public void testDouble() throws IOException {
90 matches
Mail list logo
