You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jo...@apache.org on 2024/01/26 21:17:32 UTC
(kafka) branch trunk updated: Minor update to KafkaApisTest (#15257)
This is an automated email from the ASF dual-hosted git repository.
jolshan pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 0d4e35514fe Minor update to KafkaApisTest (#15257)
0d4e35514fe is described below
commit 0d4e35514fec2548baf997f14ab5bf30cdd24c66
Author: Crispin Bernier <ch...@virginia.edu>
AuthorDate: Fri Jan 26 16:17:25 2024 -0500
Minor update to KafkaApisTest (#15257)
I was using the ZERO_UUID topicId instead of the actual topicId in the testFetchResponseContainsNewLeaderOnNotLeaderOrFollower introduced in #14444, updating as the actual topicId is more correct.
Reviewers: Justine Olshan <jo...@confluent.io>
---
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
index 1aa5862d42e..6590605bd3f 100644
--- a/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
+++ b/core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
@@ -4277,13 +4277,13 @@ class KafkaApisTest extends Logging {
Optional.empty(), OptionalLong.empty(), Optional.empty(), OptionalInt.empty(), false)))
})
- val fetchData = Map(tidp -> new FetchRequest.PartitionData(Uuid.ZERO_UUID, 0, 0, 1000,
+ val fetchData = Map(tidp -> new FetchRequest.PartitionData(topicId, 0, 0, 1000,
Optional.empty())).asJava
- val fetchDataBuilder = Map(tp -> new FetchRequest.PartitionData(Uuid.ZERO_UUID, 0, 0, 1000,
+ val fetchDataBuilder = Map(tp -> new FetchRequest.PartitionData(topicId, 0, 0, 1000,
Optional.empty())).asJava
val fetchMetadata = new JFetchMetadata(0, 0)
val fetchContext = new FullFetchContext(time, new FetchSessionCache(1000, 100),
- fetchMetadata, fetchData, false, false)
+ fetchMetadata, fetchData, true, false)
when(fetchManager.newContext(
any[Short],
any[JFetchMetadata],