package Ġk af kas noop . serial isation . avro Ċ Ċ import Ġcom . pap sign . ktor . open ap igen . Open API Gen Ċ import Ġcom . pap sign . ktor . open ap igen . route . api Routing Ċ import Ġio . ktor . application .* Ċ import Ġio . ktor . routing .* Ċ import Ġio . ktor . server . engine .* Ċ import Ġio . ktor . server . netty .* Ċ import Ġio . ktor . websocket .* Ċ import Ġk af kas noop . avro . Schema Registry Ċ import Ġk af kas noop . http . install Content Neg otiation Ċ import Ġk af kas noop . serial isation . avro . routes . serial iser Api Routes Ċ import Ġk af kas noop . serial isation . avro . routes . serial iser Routes Ċ import Ġkotlinx . coroutines . Experimental Cor outines Api Ċ import Ġorg . slf 4 j . LoggerFactory Ċ Ċ class ĠServer ( ĊĠĠĠ Ġprivate Ġval Ġschema Registry : ĠSchema Registry , ĊĠĠĠ Ġprivate Ġval Ġmessage Envelope Options : ĠMessage Schema Options Ċ ) Ġ{ ĊĊĠĠĠ Ġcompanion Ġobject Ġ{ ĊĠĠĠĠĠĠĠ Ġprivate Ġval Ġlogger Ġ= ĠLoggerFactory . getLogger ( Server :: class . java ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Experimental Cor outines Api ĊĠĠĠ Ġfun Ġstart ( port : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġlogger . info (" Starting ĠHTTP Ġserver ") ĊĠĠĠĠĠĠĠ Ġembedded Server ( Net ty , Ġport Ġ= Ġport ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġserial isation Server ( schema Registry , Ġmessage Envelope Options ) ĊĠĠĠĠĠĠĠ Ġ}. start ( wait Ġ= Ġtrue ) ĊĠĠĠ Ġ} Ċ } Ċ Ċ fun ĠApplication . serial isation Server ( ĊĠĠĠ Ġschema Registry : ĠSchema Registry , ĊĠĠĠ Ġmessage Envelope Options : ĠMessage Schema Options Ċ ) Ġ{ ĊĠĠĠ Ġinstall Content Neg otiation () ĊĠĠĠ Ġinstall ( WebSocket s ) ĊĠĠĠ Ġinstall ( Open API Gen ) Ġ{ ĊĠĠĠĠĠĠĠ Ġ// Ġbasic Ġinfo ĊĠĠĠĠĠĠĠ Ġinfo Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġversion Ġ= Ġ" 0 . 0 . 3 " ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtitle Ġ= Ġ" Kafka S noop ĠAV RO ĠSerial isation ĠAPI " ĊĠĠĠĠĠĠĠĠĠĠĠ Ġdescription Ġ= Ġ" HTTP ĠAPI Ġfor ĠAV RO ĠSerial isation " ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġrouting Ġ{ ĊĠĠĠĠĠĠĠ Ġ// ĠNOTE : Ġopen API Ġrouting Ġwasn 't Ġworking , ĠI Ġthink Ġbecause Ġof Ġa Ġbug Ġin Ġthe Ġbinary Ġpayload Ġhandling ĊĠĠĠĠĠĠĠ Ġ// Ġ Ġwill Ġcome Ġback Ġto Ġthis Ġlater ĊĠĠĠĠĠĠĠ Ġserial iser Routes ( schema Registry , Ġmessage Envelope Options ) ĊĠĠĠ Ġ} ĊĠĠĠ Ġapi Routing Ġ{ ĊĠĠĠĠĠĠĠ Ġserial iser Api Routes ( schema Registry ) ĊĠĠĠ Ġ} Ċ } Ċ