root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

HOTFIX: Fix IQv2EndpointToPartitionsIntegrationTest (#19597)
CI / build (push) Waiting to run Details 

It seems that IQv2EndpointToPartitionsIntegrationTest uses a
non-existent method to create `EmbeddedKafkaCluster`

Reviewers: Luke Chen <showuon@gmail.com>, PoAn Yang <payang@apache.org>,
Ken Huang <s7133700@gmail.com>
This commit is contained in:
TengYao Chi 2025-04-30 15:33:09 +08:00 committed by GitHub
parent f5b8891b0c
commit 08f6042f7a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/IQv2EndpointToPartitionsIntegrationTest.java
View File

@ -72,7 +72,7 @@ public class IQv2EndpointToPartitionsIntegrationTest {
public void startCluster(final int standbyConfig) throws IOException {
final Properties properties = new Properties();
properties.put(GroupCoordinatorConfig.STREAMS_GROUP_NUM_STANDBY_REPLICAS_CONFIG, standbyConfig);
cluster = EmbeddedKafkaCluster.withStreamsRebalanceProtocol(NUM_BROKERS, properties);
cluster = new EmbeddedKafkaCluster(NUM_BROKERS, properties);
cluster.start();
}