ahuang98 commented on code in PR #16637:
URL: https://github.com/apache/kafka/pull/16637#discussion_r1687208680
##########
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientTest.java:
##########
@@ -2763,78 +2765,396 @@ public void testDescribeQuorumNonLeader(boolean
withKip853Rpc) throws Exception
}
@ParameterizedTest
- @ValueSource(booleans = { true, false })
- public void testDescribeQuorum(boolean withKip853Rpc) throws Exception {
- int localId = randomReplicaId();
- ReplicaKey closeFollower = replicaKey(localId + 2, withKip853Rpc);
- ReplicaKey laggingFollower = replicaKey(localId + 1, withKip853Rpc);
- Set<Integer> voters = Utils.mkSet(localId, closeFollower.id(),
laggingFollower.id());
+ @CsvSource({ "true,0", "true,1", "false,0", "false,1" })
+ public void testDescribeQuorumOld(boolean withKip853Rpc, short apiVersion)
throws Exception {
+ int localId = 0;
+ ReplicaKey local = replicaKey(localId, withKip853Rpc);
+ ReplicaKey follower1 = replicaKey(1, withKip853Rpc);
+ Set<Integer> voters = Utils.mkSet(localId, follower1.id());
+ VoterSet voterSet = VoterSetTest.voterSet(Stream.of(local, follower1));
+
+ RaftClientTestContext.Builder builder = new
RaftClientTestContext.Builder(localId,
local.directoryId().orElse(ReplicaKey.NO_DIRECTORY_ID))
+ .withStaticVoters(voters)
+ .withKip853Rpc(true);
Review Comment:
I'm aware that `withKip853Rpc` defines the versions of RPCs to send. The
distinction I'm trying to make is `withKip853Rpc` does more than define what
RPC versions to send in the test, it also defines what the local replica
supports (for instance, if directory ids are supported) which can be different
than what other replicas support.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
