Enabled Describe Consumer Group Test for Consumer Group Protocol

[PratRanj07]

This PR aims to:

• Enabled Describe Consumer Group test for Consumer Group Protocol
• Test compatibility of describing new protocol consumer group along with old protocol consumer group

[confluent-cla-assistant]

🎉 All Contributor License Agreements have been signed. Ready to merge.
_{Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.}

[Copilot]

Pull Request Overview

This PR enables testing for the Describe Consumer Group API with both the new and legacy consumer group protocols. Key changes include:

• Adding new functions (test_create_consumer0, test_create_handle0, and test_conf_set0) to support a protocol flag.
• Updating conditional logic in consumer creation and configuration functions to handle the environment_group_protocol flag.
• Adjusting timeouts, protocol expectations, and test infrastructure (semaphore configuration) to align with the new protocol.

Reviewed Changes

Copilot reviewed 4 out of 4 changed files in this pull request and generated 3 comments.

File	Description
tests/test.h	Introduces new function test_create_consumer0 with an added environment_group_protocol parameter
tests/test.c	Implements test_create_handle0 and updates test_create_consumer logic to conditionally handle protocol changes
tests/0081-admin.c	Updates protocol count, session timeout values, and assertions for consumer group tests
.semaphore/semaphore.yml	Modifies test cluster invocation command and configuration to match new protocol settings

Comments suppressed due to low confidence (2)

tests/test.h:549

• [nitpick] Consider using a more descriptive suffix or naming convention for alternative consumer creation functions instead of simply appending '0'.

rd_kafka_t *test_create_consumer0(

tests/test.c:2182

• [nitpick] Consider renaming 'test_create_handle0' to clarify that this function underlies the public 'test_create_handle' wrapper and accepts an environment_group_protocol flag.

                                rd_bool_t environment_group_protocol) {

[Copilot]

[nitpick] The conditional logic in test_create_consumer based on the environment_group_protocol flag may be confusing. Consider adding inline documentation to explain the rationale for the inverted branch behavior.

Suggested change

	/* Create kafka instance */
	rk = test_create_handle(RD_KAFKA_CONSUMER, conf);
	if (!environment_group_protocol) {
	rk = test_create_handle0(RD_KAFKA_CONSUMER, conf,
	environment_group_protocol);
	} else {
	/* Create kafka instance */
	/* If environment_group_protocol is false, use test_create_handle0.
	* This is typically used for scenarios where additional configuration
	* or handling is required during consumer creation. */
	if (!environment_group_protocol) {
	rk = test_create_handle0(RD_KAFKA_CONSUMER, conf,
	environment_group_protocol);
	} else {
	/* If environment_group_protocol is true, use test_create_handle.
	* This is the standard consumer creation method. */

[Copilot]

[nitpick] The hard-coded value '6000' for the session timeout in the Classic protocol branch is a magic number. Consider introducing a named constant to enhance clarity and maintainability.

Suggested change

	"6000", rd_false);
	CLASSIC_PROTOCOL_SESSION_TIMEOUT_MS, rd_false);

[Copilot]

[nitpick] The increased sleep duration (from 6 to 8 seconds) is hard-coded. Consider defining this value as a constant to document its intent and simplify future adjustments.

Suggested change

	rd_sleep(8);
	rd_sleep(SESSION_TIMEOUT_SLEEP_DURATION);