(nifi) branch main updated: NIFI-16356 Removed redundant type casts. (#11690)

[pvillard]

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

pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new d0c2cc10f98 NIFI-16356 Removed redundant type casts. (#11690)
d0c2cc10f98 is described below

commit d0c2cc10f98e188d745c420792ea78a3ed26a7e9
Author: dan-s1 <dsti...@gmail.com>
AuthorDate: Thu Sep 17 09:32:42 2026 -0400

    NIFI-16356 Removed redundant type casts. (#11690)
---
 .../org/apache/nifi/kafka/processors/ConsumeKafkaBacklogIT.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaBacklogIT.java
 
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaBacklogIT.java
index 62f719b3ff8..3aaf0842d25 100644
--- 
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaBacklogIT.java
+++ 
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/ConsumeKafkaBacklogIT.java
@@ -88,7 +88,7 @@ class ConsumeKafkaBacklogIT extends AbstractConsumeKafkaIT {
         final Backlog backlog = requireBacklog();
         assertEquals(Backlog.Precision.EXACT, backlog.getPrecision());
         assertTrue(backlog.getRecordCount().isPresent());
-        assertEquals((long) (seedCount - delivered), 
backlog.getRecordCount().getAsLong());
+        assertEquals(seedCount - delivered, 
backlog.getRecordCount().getAsLong());
         assertFalse(backlog.getLastCaughtUp().isPresent());
     }
 
@@ -149,7 +149,7 @@ class ConsumeKafkaBacklogIT extends AbstractConsumeKafkaIT {
         final Backlog reLagBacklog = requireBacklog();
         assertEquals(Backlog.Precision.EXACT, reLagBacklog.getPrecision());
         assertTrue(reLagBacklog.getRecordCount().isPresent());
-        assertEquals((long) (reSeed - redelivered), 
reLagBacklog.getRecordCount().getAsLong());
+        assertEquals(reSeed - redelivered, 
reLagBacklog.getRecordCount().getAsLong());
         assertTrue(reLagBacklog.getLastCaughtUp().isPresent());
         assertSame(priorCaughtUp, reLagBacklog.getLastCaughtUp().get());
     }
@@ -168,7 +168,7 @@ class ConsumeKafkaBacklogIT extends AbstractConsumeKafkaIT {
         final Backlog backlog = requireBacklog();
         assertEquals(Backlog.Precision.EXACT, backlog.getPrecision());
         assertTrue(backlog.getRecordCount().isPresent());
-        assertEquals((long) seedCount, backlog.getRecordCount().getAsLong());
+        assertEquals(seedCount, backlog.getRecordCount().getAsLong());
         assertFalse(backlog.getLastCaughtUp().isPresent());
     }