(kafka) branch trunk updated: [MINOR] Removing unused variables from StreamThreadTest (#14777)

[lucasbru]

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

lucasbru 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 e7f4f5dfe7e [MINOR] Removing unused variables from StreamThreadTest 
(#14777)
e7f4f5dfe7e is described below

commit e7f4f5dfe7ef2c95f3e9a1dbbeded8502d3e1e05
Author: vamossagar12 <sagarmeansoc...@gmail.com>
AuthorDate: Thu Nov 16 15:30:11 2023 +0530

    [MINOR] Removing unused variables from StreamThreadTest (#14777)
    
    A few variables which aren't being used anymore but still exist. This 
commit removes those unused variables.
    
    Co-authored-by: Sagar Rao <sagarrao@Sagars-MacBook-Pro.local>
    Reviewers: Lucas Brutschy <lbruts...@confluent.io>
---
 .../kafka/streams/processor/internals/StreamThreadTest.java | 13 -------------
 1 file changed, 13 deletions(-)

diff --git 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
index e0990174168..76de86ec597 100644
--- 
a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
+++ 
b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java
@@ -3110,8 +3110,6 @@ public class StreamThreadTest {
         // expect not to try and commit task3, because it's not running.
         expect(taskManager.commit(mkSet(task1, task2))).andReturn(2).times(1);
 
-        final StreamsMetricsImpl streamsMetrics =
-            new StreamsMetricsImpl(metrics, CLIENT_ID, 
StreamsConfig.METRICS_LATEST, mockTime);
         final TopologyMetadata topologyMetadata = new 
TopologyMetadata(internalTopologyBuilder, config);
         topologyMetadata.buildAndRewriteTopology();
         thread = buildStreamThread(consumer, taskManager, config, 
topologyMetadata);
@@ -3153,17 +3151,6 @@ public class StreamThreadTest {
         thread.rebalanceListener().onPartitionsAssigned(assignedPartitions);
         runOnce();
 
-        final MetricName skippedTotalMetric = metrics.metricName(
-            "skipped-records-total",
-            "stream-metrics",
-            Collections.singletonMap("client-id", thread.getName())
-        );
-        final MetricName skippedRateMetric = metrics.metricName(
-            "skipped-records-rate",
-            "stream-metrics",
-            Collections.singletonMap("client-id", thread.getName())
-        );
-
         try (final LogCaptureAppender appender = 
LogCaptureAppender.createAndRegister(RecordQueue.class)) {
             long offset = -1;
             addRecord(mockConsumer, ++offset);