This is an automated email from the ASF dual-hosted git repository.
chia7712 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 de029ac73eb MINOR: Remove unstable.api.version.enable config and
rename corresponding test from StreamsGroupHeartbeatRequestTest (#21132)
de029ac73eb is described below
commit de029ac73eb521c70fb0fccca8c885c17b42e03e
Author: lucliu1108 <[email protected]>
AuthorDate: Sun Dec 21 06:11:19 2025 -0600
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 <[email protected]>, Chia-Ping Tsai
<[email protected]>
---
.../unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala | 9 ++-------
1 file changed, 2 insertions(+), 7 deletions(-)
diff --git
a/core/src/test/scala/unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala
b/core/src/test/scala/unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala
index 252ee82fb14..46d3e2a950a 100644
---
a/core/src/test/scala/unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala
+++
b/core/src/test/scala/unit/kafka/server/StreamsGroupHeartbeatRequestTest.scala
@@ -35,7 +35,6 @@ import scala.jdk.CollectionConverters._
serverProperties = Array(
new ClusterConfigProperty(key =
GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG, value = "1"),
new ClusterConfigProperty(key =
GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, value = "1"),
- new ClusterConfigProperty(key = "unstable.api.versions.enable", value =
"true"),
new ClusterConfigProperty(key = "group.coordinator.rebalance.protocols",
value = "classic,consumer,streams"),
new ClusterConfigProperty(key =
"group.streams.initial.rebalance.delay.ms", value = "0")
)
@@ -111,12 +110,8 @@ class StreamsGroupHeartbeatRequestTest(cluster:
ClusterInstance) extends GroupCo
assertEquals(expectedResponse, streamsGroupHeartbeatResponse)
}
- @ClusterTest(
- serverProperties = Array(
- new ClusterConfigProperty(key =
GroupCoordinatorConfig.GROUP_COORDINATOR_REBALANCE_PROTOCOLS_CONFIG, value =
"classic,consumer,streams"),
- )
- )
- def
testStreamsGroupHeartbeatIsInaccessibleWhenUnstableLatestVersionNotEnabled():
Unit = {
+ @ClusterTest
+ def testStreamsGroupHeartbeatIsInaccessibleWhenOffsetTopicNotExist(): Unit =
{
val topology = new StreamsGroupHeartbeatRequestData.Topology()
.setEpoch(1)
.setSubtopologies(List().asJava)
