gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix tests

Browse Source
This commit is contained in:
Chris Lu
2026-03-23 19:36:14 -07:00
parent e5f72077ee
commit 2844c70ecf
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
test/kafka/e2e/offset_management_test.go
View File

@@ -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")
})
}