This is an automated email from the ASF dual-hosted git repository. dajac pushed a commit to branch 4.0 in repository https://gitbox.apache.org/repos/asf/kafka.git
commit 0c433a2c014696012c53a755a77eceaf0d971fc7 Author: David Jacot <[email protected]> AuthorDate: Tue Dec 17 20:09:45 2024 +0100 KAFKA-17960; PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol (#18234) The issue has been fixed by https://issues.apache.org/jira/browse/KAFKA-18188. We can re-enable the test with the CONSUMER protocol. Reviewers: Lianet Magrans <[email protected]>, Andrew Schofield <[email protected]> --- .../scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala | 4 ++-- core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala | 3 --- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala index 890aff6da1e..e62ffdf7ff7 100644 --- a/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala +++ b/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala @@ -1810,7 +1810,7 @@ class PlaintextAdminIntegrationTest extends BaseAdminIntegrationTest { * Test the consumer group APIs. */ @ParameterizedTest(name = TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames) - @MethodSource(Array("getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_17960")) + @MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll")) def testConsumerGroups(quorum: String, groupProtocol: String): Unit = { val config = createConfig client = Admin.create(config) @@ -2167,7 +2167,7 @@ class PlaintextAdminIntegrationTest extends BaseAdminIntegrationTest { * Test the consumer group APIs. */ @ParameterizedTest(name = TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames) - @MethodSource(Array("getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_17960")) + @MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll")) def testConsumerGroupsDeprecatedConsumerGroupState(quorum: String, groupProtocol: String): Unit = { val config = createConfig client = Admin.create(config) diff --git a/core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala b/core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala index 9c9067ef113..a8a66dbd54f 100755 --- a/core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala +++ b/core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala @@ -444,8 +444,5 @@ object QuorumTestHarness { // The following parameter groups are to *temporarily* avoid bugs with the CONSUMER group protocol Consumer // implementation that would otherwise cause tests to fail. - def getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_17960: stream.Stream[Arguments] = getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly - def getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_17961: stream.Stream[Arguments] = getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly - def getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_17964: stream.Stream[Arguments] = getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly def getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_KAFKA_18034: stream.Stream[Arguments] = getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly }
