/* Ċ Ġ* ĠCopyright Ġ 2 0 1 9 ĠRed ĠHat , ĠInc . Ċ Ġ* Ċ Ġ* ĠAll Ġrights Ġreserved . ĠThis Ġprogram Ġand Ġthe Ġaccompanying Ġmaterials Ċ Ġ* Ġare Ġmade Ġavailable Ġunder Ġthe Ġterms Ġof Ġthe ĠEclipse ĠPublic ĠLicense Ġv 1 . 0 Ċ Ġ* Ġand ĠApache ĠLicense Ġv 2 . 0 Ġwhich Ġaccomp anies Ġthis Ġdistribution . Ċ Ġ* Ċ Ġ* ĠThe ĠEclipse ĠPublic ĠLicense Ġis Ġavailable Ġat Ċ Ġ* Ġhttp :// www . eclipse . org / legal / e pl - v 1 0 . html Ċ Ġ* Ċ Ġ* ĠThe ĠApache ĠLicense Ġv 2 . 0 Ġis Ġavailable Ġat Ċ Ġ* Ġhttp :// www . opensource . org / licenses / apache 2 . 0 . php Ċ Ġ* Ċ Ġ* ĠYou Ġmay Ġelect Ġto Ġredistribute Ġthis Ġcode Ġunder Ġeither Ġof Ġthese Ġlicenses . Ċ Ġ*/ Ċ package Ġio . vertx . kotlin . kafka . admin Ċ Ċ import Ġio . vertx . kafka . admin . Cluster Description Ċ import Ġio . vertx . kafka . admin . Consumer Group Description Ċ import Ġio . vertx . kafka . admin . Consumer Group Listing Ċ import Ġio . vertx . kafka . admin . Kafka Admin Client Ċ import Ġio . vertx . kafka . admin . New Partitions Ċ import Ġio . vertx . kafka . admin . New Topic Ċ import Ġio . vertx . kafka . admin . Topic Description Ċ import Ġio . vertx . kafka . client . common . Topic Partition Ċ import Ġio . vertx . kotlin . coroutines . await Result Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . list Topics ] Ċ Ġ* Ċ Ġ* Ġ@ return Ġ[ Set < String >] Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġlist Topics Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" list Topics (). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . list Topics Await (): ĠSet < String > Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . list Topics ( it ) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . describe Topics ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġtopic Names Ġthe Ġnames Ġof Ġthe Ġtopics Ġto Ġdescribe Ċ Ġ* Ġ@ return Ġ[ Map < String , Topic Description >] Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdescribe Topics Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" describe Topics ( topic Names ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . describe Topics Await ( topic Names : ĠList < String >): ĠMap < String , Topic Description > Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . describe Topics ( topic Names , Ġit ) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . create Topics ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġtopics Ġtopics Ġto Ġcreate Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġcreate Topics Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" create Topics ( topics ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . create Topics Await ( topics : ĠList < New Topic >): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . create Topics ( topics , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . delete Topics ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġtopic Names Ġthe Ġnames Ġof Ġthe Ġtopics Ġto Ġdelete Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdelete Topics Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" delete Topics ( topic Names ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . delete Topics Await ( topic Names : ĠList < String >): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . delete Topics ( topic Names , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . create Partitions ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġpartitions Ġpartitions Ġto Ġcreate Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġcreate Partitions Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" create Partitions ( partitions ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . create Partitions Await ( partitions : ĠMap < String , New Partitions >): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . create Partitions ( partitions , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . list Consumer Groups ] Ċ Ġ* Ċ Ġ* Ġ@ return Ġ[ List < Consumer Group Listing >] Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġlist Consumer Groups Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" list Consumer Groups (). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . list Consumer Groups Await (): ĠList < Consumer Group Listing > Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . list Consumer Groups ( it ) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . describe Consumer Groups ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġgroup Ids Ġthe Ġids Ġof Ġthe Ġgroups Ġto Ġdescribe Ċ Ġ* Ġ@ return Ġ[ Map < String , Consumer Group Description >] Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdescribe Consumer Groups Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" describe Consumer Groups ( group Ids ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . describe Consumer Groups Await ( group Ids : ĠList < String >): ĠMap < String , Consumer Group Description > Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . describe Consumer Groups ( group Ids , Ġit ) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . describe Cluster ] Ċ Ġ* Ċ Ġ* Ġ@ return Ġ[ Cluster Description ] Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdescribe Cluster Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" describe Cluster (). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . describe Cluster Await (): ĠCluster Description Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . describe Cluster ( it ) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . delete Consumer Groups ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġgroup Ids Ġthe Ġids Ġof Ġthe Ġgroups Ġto Ġdelete Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdelete Consumer Groups Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" delete Consumer Groups ( group Ids ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . delete Consumer Groups Await ( group Ids : ĠList < String >): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . delete Consumer Groups ( group Ids , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . delete Consumer Group Offsets ] Ċ Ġ* Ċ Ġ* Ġ@ param ĠgroupId ĠThe Ġgroup Ġid Ġof Ġthe Ġgroup Ġwhose Ġoffsets Ġwill Ġbe Ġdeleted Ċ Ġ* Ġ@ param Ġpartitions ĠThe Ġset Ġof Ġpartitions Ġin Ġthe Ġconsumer Ġgroup Ġwhose Ġoffsets Ġwill Ġbe Ġdeleted Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġdelete Consumer Group Offsets Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" delete Consumer Group Offsets ( groupId , Ġpartitions ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . delete Consumer Group Offsets Await ( groupId : ĠString , Ġpartitions : ĠSet < Topic Partition >): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . delete Consumer Group Offsets ( groupId , Ġpartitions , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . close ] Ċ Ġ* Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġclose Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" close (). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . close Await (): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . close ( io . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } Ċ Ċ /** Ċ Ġ* ĠS us pending Ġversion Ġof Ġmethod Ġ[ io . vertx . kafka . admin . Kafka Admin Client . close ] Ċ Ġ* Ċ Ġ* Ġ@ param Ġtimeout Ġtimeout Ġto Ġwait Ġfor Ġclosing Ċ Ġ* Ċ Ġ* ĠNOTE : ĠThis Ġfunction Ġhas Ġbeen Ġautomatically Ġgenerated Ġfrom Ġ[ io . vertx . kafka . admin . Kafka Admin Client ] Ġusing ĠVert . x Ġcodegen . Ċ Ġ*/ Ċ @ Deprecated ( message Ġ= Ġ" Instead Ġuse Ġclose Ġreturning Ġa Ġfuture Ġand Ġchain Ġwith Ġawait ()", Ġreplace With Ġ= ĠReplace With (" close ( timeout ). await () ")) Ċ suspend Ġfun ĠKafka Admin Client . close Await ( timeout : ĠLong ): ĠUnit Ġ{ ĊĠ Ġreturn Ġawait Result Ġ{ ĊĠĠĠ Ġthis . close ( timeout , Ġio . vertx . core . Handler Ġ{ Ġar Ġ-> Ġit . handle ( ar . map Empty ()) Ġ}) ĊĠ Ġ} Ċ } ĊĊ