Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

KAFKA-18659: librdkafka compressed produce fails unless api versions returns produce v0 #18727

Merged
Prev Previous commit
Next Next commit
Fix failing test
ijuma committed Jan 30, 2025
commit b38a7ef233f05701a0a25cb24d7111eb455ee76e
Original file line number Diff line number Diff line change
@@ -55,7 +55,7 @@ public void testBrokerApiVersionsCommandOutput(ClusterInstance clusterInstance)
ApiMessageType.ListenerType listenerType = ApiMessageType.ListenerType.BROKER;

NodeApiVersions nodeApiVersions = new NodeApiVersions(
ApiVersionsResponse.collectApis(ApiKeys.clientApis(), true),
ApiVersionsResponse.filterApis(listenerType, true, true),
Collections.emptyList());
Iterator<ApiKeys> apiKeysIter = ApiKeys.clientApis().iterator();
while (apiKeysIter.hasNext()) {
@@ -64,7 +64,7 @@ public void testBrokerApiVersionsCommandOutput(ClusterInstance clusterInstance)
StringBuilder lineBuilder = new StringBuilder().append("\t");
if (apiKey.inScope(listenerType)) {
ApiVersion apiVersion = nodeApiVersions.apiVersion(apiKey);
assertNotNull(apiVersion);
assertNotNull(apiVersion, "No apiVersion found for " + apiKey);

String versionRangeStr = (apiVersion.minVersion() == apiVersion.maxVersion()) ?
String.valueOf(apiVersion.minVersion()) :