DL1231 commented on code in PR #16859:
URL: https://github.com/apache/kafka/pull/16859#discussion_r1715106585
##########
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##########
@@ -925,6 +925,66 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIntegrationTest {
checkValidAlterConfigs(client, this, topicResource1, topicResource2)
}
+ @ParameterizedTest
+ @ValueSource(strings = Array("kraft+kip848"))
+ def testIncrementalAlterAndDescribeGroupConfigs(quorum: String): Unit = {
+ client = createAdminClient
+ val group = "describe-alter-configs-group"
+ val groupResource = new ConfigResource(ConfigResource.Type.GROUP, group)
+
+ // Alter group configs
+ var groupAlterConfigs = Seq(
+ new AlterConfigOp(new
ConfigEntry(GroupConfig.CONSUMER_SESSION_TIMEOUT_MS_CONFIG, "50000"),
AlterConfigOp.OpType.SET),
+ new AlterConfigOp(new
ConfigEntry(GroupConfig.CONSUMER_HEARTBEAT_INTERVAL_MS_CONFIG, ""),
AlterConfigOp.OpType.DELETE)
Review Comment:
What I want to test here is executing the delete operation and then
returning the default value when describing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
