morrre naming

linkedin · Oct 26, 2023 · 1da09f6 · 1da09f6
1 parent 0b21106
commit 1da09f6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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.");
     }