Fixed flaky test

kr-igor · kr-igor · commit 557cbfc3a9c5 · 2025-07-22T12:41:01.000-05:00
diff --git a/dd-java-agent/instrumentation/kafka-clients-0.11/src/latestDepTest/groovy/KafkaClientTestBase.groovy b/dd-java-agent/instrumentation/kafka-clients-0.11/src/latestDepTest/groovy/KafkaClientTestBase.groovy
@@ -247,7 +247,7 @@ abstract class KafkaClientTestBase extends VersionedNamingTestBase {
           "type:kafka"
           )
       }
-      def sorted = new ArrayList<DataStreamsTags>(TEST_DATA_STREAMS_WRITER.backlogs).sort()
+      def sorted = new ArrayList<DataStreamsTags>(TEST_DATA_STREAMS_WRITER.backlogs).sort({it.type+it.partition})
       verifyAll(sorted) {
         size() == 2
         get(0).hasAllTags("consumer_group:sender",

Original file line number	Diff line number	Diff line change
`@@ -247,7 +247,7 @@ abstract class KafkaClientTestBase extends VersionedNamingTestBase {`
`247`	`247`	`"type:kafka"`
`248`	`248`	`)`
`249`	`249`	`}`
`250`		`- def sorted = new ArrayList<DataStreamsTags>(TEST_DATA_STREAMS_WRITER.backlogs).sort()`
	`250`	`+ def sorted = new ArrayList<DataStreamsTags>(TEST_DATA_STREAMS_WRITER.backlogs).sort({it.type+it.partition})`
`251`	`251`	`verifyAll(sorted) {`
`252`	`252`	`size() == 2`
`253`	`253`	`get(0).hasAllTags("consumer_group:sender",`