Skip to content

Commit de029ac

Browse files
authored
MINOR: Remove unstable.api.version.enable config and rename corresponding test from StreamsGroupHeartbeatRequestTest (#21132)
## Summary - Remove `unstable.api.version.enable` config since it's not required. - Rename `testStreamsGroupHeartbeatIsInaccessibleWhenUnstableLatestVersionNotEnabled` to `testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist` Reviewers: Lucas Brutschy <lbrutschy@confluent.io>, Chia-Ping Tsai <chia7712@gmail.com>
1 parent 09713a3 commit de029ac

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

core/src/test/scala/unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@ import scala.jdk.CollectionConverters._
3535
serverProperties = Array(
3636
new ClusterConfigProperty(key = GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG, value = "1"),
3737
new ClusterConfigProperty(key = GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, value = "1"),
38-
new ClusterConfigProperty(key = "unstable.api.versions.enable", value = "true"),
3938
new ClusterConfigProperty(key = "group.coordinator.rebalance.protocols", value = "classic,consumer,streams"),
4039
new ClusterConfigProperty(key = "group.streams.initial.rebalance.delay.ms", value = "0")
4140
)
@@ -111,12 +110,8 @@ class StreamsGroupHeartbeatRequestTest(cluster: ClusterInstance) extends GroupCo
111110
assertEquals(expectedResponse, streamsGroupHeartbeatResponse)
112111
}
113112

114-
@ClusterTest(
115-
serverProperties = Array(
116-
new ClusterConfigProperty(key = GroupCoordinatorConfig.GROUP_COORDINATOR_REBALANCE_PROTOCOLS_CONFIG, value = "classic,consumer,streams"),
117-
)
118-
)
119-
def testStreamsGroupHeartbeatIsInaccessibleWhenUnstableLatestVersionNotEnabled(): Unit = {
113+
@ClusterTest
114+
def testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist(): Unit = {
120115
val topology = new StreamsGroupHeartbeatRequestData.Topology()
121116
.setEpoch(1)
122117
.setSubtopologies(List().asJava)

0 commit comments

Comments
 (0)