diff --git a/clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java b/clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java index 115b914f7615..27b6787026f1 100644 --- a/clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java +++ b/clients/src/test/java/org/apache/kafka/clients/producer/MockProducerTest.java @@ -740,18 +740,17 @@ public void shouldNotBeFlushedAfterFlush() { @Test public void testMetadataOnException() throws InterruptedException { buildMockProducer(false); - Future md1 = producer.send(record2, (md, exception) -> { + Future metadata = producer.send(record2, (md, exception) -> { assertNotNull(md); assertEquals(md.offset(), -1L, "Invalid offset"); assertEquals(md.timestamp(), RecordBatch.NO_TIMESTAMP, "Invalid timestamp"); - //assertEquals(md.checksum(), -1L, "Invalid checksum"); assertEquals(md.serializedKeySize(), -1L, "Invalid Serialized Key size"); assertEquals(md.serializedValueSize(), -1L, "Invalid Serialized value size"); }); IllegalArgumentException e = new IllegalArgumentException("dummy exception"); assertTrue(producer.errorNext(e), "Complete the second request with an error"); try { - md1.get(); + metadata.get(); fail("Something went wrong, expected an error"); } catch (ExecutionException err) { assertEquals(e, err.getCause());