[KIP-848]: Run perf tests for consumer protocol

[PratRanj07]

This PR intends to make changes to run Performance Tests on Semaphore with the newly introduced Consumer Group Protocol (KIP 848).

[Copilot]

Pull Request Overview

Adds support for running performance tests with the new Consumer Group Protocol (KIP-848) alongside the classic protocol by extending test helpers, consumer configuration, and CI setup.

• Introduces TEST_CONSUMER_GROUP_PROTOCOL env var and helper functions to toggle protocol behavior in tests.
• Updates createConsumer and internal config mapping to validate and strip classic-only settings when using the new protocol.
• Extends Docker Compose files and Semaphore CI pipeline to run perf tests under both classic and consumer protocols.

Reviewed Changes

Copilot reviewed 6 out of 6 changed files in this pull request and generated 1 comment.

Show a summary per file

File	Description
test/promisified/testhelpers.js	Adds testConsumerGroupProtocol* helpers and adjusts createConsumer to apply/remove settings based on protocol
test/docker/kraft/server.properties	Configures KRaft broker with consumer group protocol settings
test/docker/docker-compose-kraft.yml	Provides a Docker Compose definition for the KRaft broker used in consumer-protocol tests
lib/kafkajs/_consumer.js	Extends #kafkaJSToConsumerConfig to accept an isClassicProtocol flag and enforce validations
.semaphore/semaphore.yml	Adds two Semaphore CI jobs running perf tests for classic and consumer protocols

Comments suppressed due to low confidence (3)

test/promisified/testhelpers.js:18

• Add a JSDoc or inline comment explaining that TEST_CONSUMER_GROUP_PROTOCOL should be set to either 'classic' or 'consumer', and what the helper returns in each case.

function testConsumerGroupProtocol() {

lib/kafkajs/_consumer.js:515

• For non-classic protocols, no default partition.assignment.strategy is set. If this is intentional, consider adding a comment to clarify fallback behavior or explicitly document the absence of a default strategy.

} else if (isClassicProtocol) {

.semaphore/semaphore.yml:170

• This line and the following commands lack a '+' prefix in the diff, so they won’t be added under the new consumer-protocol job. Ensure the NODE_OPTIONS, working directory change, and npm install commands are included in the patch.

              - export NODE_OPTIONS='--max-old-space-size=1536'

[Copilot]

[nitpick] Since testConsumerGroupProtocol is defined but not exported, either export it for clarity or rename it (e.g., _testConsumerGroupProtocol) to indicate it’s intended as a private helper.

[sonarqube-confluent]

• 48.30% Coverage on New Code (is less than 80.00%)

Analysis Details

1 Issue

• 0 Bugs
• 0 Vulnerabilities
• 1 Code Smell

Coverage and Duplications

• 48.30% Coverage (48.60% Estimated after merge)
• No duplication information (2.00% Estimated after merge)

Project ID: confluent-kafka-javascript

View in SonarQube