(kafka) branch trunk updated: HOTFIX: Fix compilation error in TransactionManagerTest (#15405)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cadonna pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new cc49fc76564 HOTFIX: Fix compilation error in TransactionManagerTest (#15405)
cc49fc76564 is described below

commit cc49fc76564b15f2111801faf62341aaf01c4d8c
Author: Bruno Cadonna <ca...@apache.org>
AuthorDate: Wed Feb 21 11:54:46 2024 +0100

    HOTFIX: Fix compilation error in TransactionManagerTest (#15405)
    
    Variable metadataMock was removed by #15323 after the CI build of #15320 was run and before #15320 was merged.
    
    Reviewers: Luke Chen <sh...@gmail.com>, Lucas Brutschy <lb...@confluent.io>
---
 .../kafka/clients/producer/internals/TransactionManagerTest.java       | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java b/clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java
index de02738a34a..b099ebfc419 100644
--- a/clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java
+++ b/clients/src/test/java/org/apache/kafka/clients/producer/internals/TransactionManagerTest.java
@@ -2550,8 +2550,7 @@ public class TransactionManagerTest {
         transactionManager.maybeAddPartition(tp0);
         accumulator.beginFlush();
 
-        drainedBatches = accumulator.drain(metadataMock, nodes, Integer.MAX_VALUE,
-            time.milliseconds());
+        drainedBatches = accumulator.drain(metadataCache, nodes, Integer.MAX_VALUE, time.milliseconds());
 
         // We still shouldn't drain batches because the partition call didn't complete yet.
         assertTrue(drainedBatches.containsKey(node1.id()));