OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r1867146038
##########
clients/src/test/java/org/apache/kafka/clients/producer/internals/SenderTest.java:
##########
@@ -579,8 +595,11 @@ public void testNodeLatencyStats() throws Exception {
new BufferPool(totalSize, batchSize, m, time,
"producer-internal-metrics"));
SenderMetricsRegistry senderMetrics = new SenderMetricsRegistry(m);
+ ApiVersions apiVersions1 = new ApiVersions();
+ apiVersions1.update("0",
NodeApiVersions.create(ApiKeys.PRODUCE.id, (short) 0, (short) 12));
Review Comment:
I actually don't remember why I created another one, I have removed this and
the test isn't failing so am assuming It was a mistake
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
