Skip to content

Commit c199418

Browse files
authored
MINOR: Remove the unused parameter from FetchSession update method (#19414)
Reviewers: PoAn Yang <[email protected]>, Ken Huang <[email protected]>, Jhen-Yung Hsu <[email protected]>, Chia-Ping Tsai <[email protected]>
1 parent c6496e0 commit c199418

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

core/src/main/scala/kafka/server/FetchSession.scala

+2-3
Original file line numberDiff line numberDiff line change
@@ -270,8 +270,7 @@ class FetchSession(val id: Int,
270270

271271
// Update the cached partition data based on the request.
272272
def update(fetchData: FetchSession.REQ_MAP,
273-
toForget: util.List[TopicIdPartition],
274-
reqMetadata: JFetchMetadata): (TL, TL, TL) = synchronized {
273+
toForget: util.List[TopicIdPartition]): (TL, TL, TL) = synchronized {
275274
val added = new TL
276275
val updated = new TL
277276
val removed = new TL
@@ -880,7 +879,7 @@ class FetchManager(private val time: Time,
880879
s", but request version $reqVersion means that we can not.")
881880
new SessionErrorContext(Errors.FETCH_SESSION_TOPIC_ID_ERROR, reqMetadata)
882881
} else {
883-
val (added, updated, removed) = session.update(fetchData, toForget, reqMetadata)
882+
val (added, updated, removed) = session.update(fetchData, toForget)
884883
if (session.isEmpty) {
885884
debug(s"Created a new sessionless FetchContext and closing session id ${session.id}, " +
886885
s"epoch ${session.epoch}: after removing ${partitionsToLogString(removed)}, " +

0 commit comments

Comments
 (0)