From 1da09f6e59eadf5777595272d3adc41c9c5de7bd Mon Sep 17 00:00:00 2001 From: kehu Date: Thu, 26 Oct 2023 14:55:33 -0700 Subject: [PATCH] morrre naming --- core/src/main/scala/kafka/network/RequestConvertToJson.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/network/RequestConvertToJson.scala b/core/src/main/scala/kafka/network/RequestConvertToJson.scala index 981f96c7ad99b..6b76c11a55fd5 100644 --- a/core/src/main/scala/kafka/network/RequestConvertToJson.scala +++ b/core/src/main/scala/kafka/network/RequestConvertToJson.scala @@ -98,7 +98,7 @@ object RequestConvertToJson { case req: LiControlledShutdownSkipSafetyCheckRequest => LiControlledShutdownSkipSafetyCheckRequestDataJsonConverter.write(req.data, request.version) case req: LiCombinedControlRequest => LiCombinedControlRequestDataJsonConverter.write(req.data, request.version()) case req: LiMoveControllerRequest => LiMoveControllerRequestDataJsonConverter.write(req.data, request.version()) - case req: LiFederatedTopicCreateRequest => LiXinfraTopicCreateRequestDataJsonConverter.write(req.data, request.version()) + case req: LiFederatedTopicCreateRequest => LiFederatedTopicCreateRequestDataJsonConverter.write(req.data, request.version()) case _ => throw new IllegalStateException(s"ApiKey ${request.apiKey} is not currently handled in `request`, the " + "code should be updated to do so."); } @@ -177,7 +177,7 @@ object RequestConvertToJson { case res: LiControlledShutdownSkipSafetyCheckResponse => LiControlledShutdownSkipSafetyCheckResponseDataJsonConverter.write(res.data, version) case res: LiCombinedControlResponse => LiCombinedControlResponseDataJsonConverter.write(res.data, version) case res: LiMoveControllerResponse => LiMoveControllerResponseDataJsonConverter.write(res.data, version) - case res: LiFederatedTopicCreateResponse => LiXinfraTopicCreateResponseDataJsonConverter.write(res.data, version) + case res: LiFederatedTopicCreateResponse => LiFederatedTopicCreateResponseDataJsonConverter.write(res.data, version) case _ => throw new IllegalStateException(s"ApiKey ${response.apiKey} is not currently handled in `response`, the " + "code should be updated to do so."); }