From 2844c70ecf5d332ce50709006aa6f98609530b12 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Mon, 23 Mar 2026 19:36:14 -0700 Subject: [PATCH] fix tests --- test/kafka/e2e/offset_management_test.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/test/kafka/e2e/offset_management_test.go b/test/kafka/e2e/offset_management_test.go index 11bbdc5ea..0df5b9d43 100644 --- a/test/kafka/e2e/offset_management_test.go +++ b/test/kafka/e2e/offset_management_test.go @@ -27,17 +27,19 @@ func TestOffsetManagement(t *testing.T) { t.Logf("Running offset management tests with mock backend - offsets are in-memory only") } - topic := testutil.GenerateUniqueTopicName("offset-management") + topic1 := testutil.GenerateUniqueTopicName("offset-management") + topic2 := testutil.GenerateUniqueTopicName("offset-resumption") groupID := testutil.GenerateUniqueGroupID("offset-test-group") - gateway.AddTestTopic(topic) + gateway.AddTestTopic(topic1) + gateway.AddTestTopic(topic2) t.Run("BasicOffsetCommitFetch", func(t *testing.T) { - testBasicOffsetCommitFetch(t, addr, topic, groupID) + testBasicOffsetCommitFetch(t, addr, topic1, groupID) }) t.Run("ConsumerGroupResumption", func(t *testing.T) { - testConsumerGroupResumption(t, addr, topic, groupID+"2") + testConsumerGroupResumption(t, addr, topic2, groupID+"2") }) }