package Ġorg . un bro k end ome . embedded . kafka . junit 5 Ċ Ċ import Ġorg . junit . jupiter . api . extension . Extension Context Ċ import Ġorg . junit . jupiter . api . extension . Parameter Context ĊĊ Ċ /** Ċ Ġ* ĠRes olves Ġmethod Ġarguments Ġfor Ġparameters Ġannotated Ġwith Ġ[ Embedded Kafka Address ]. Ċ Ġ*/ Ċ class ĠKafka Address Argument Resolver Ġ: ĠArgument Resolver Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġsupports ( parameter Context : ĠParameter Context , Ġextension Context : ĠExtension Context ): ĠBoolean Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġparameter Context . parameter ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. is Annotation Present ( Embedded Kafka Address :: class . java ) ĊĊĊĠĠĠ Ġoverride Ġfun Ġresolve ( parameter Context : ĠParameter Context , ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġextension Context : ĠExtension Context ): ĠAny ? Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġextension Context . embedded Kafka . let Ġ{ Ġembedded Kafka Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġwhen Ġ( parameter Context . parameter . type ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠString :: class . java Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġembedded Kafka . bootstrap Servers ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ ĠInt :: class . java Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġembedded Kafka . port ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġelse Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠIllegalArgumentException (" Parameter Ġannotated Ġwith Ġ@ Embedded Kafka Address Ġmust Ġ" Ġ+ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" be Ġof Ġtype ĠString Ġor ĠInt ") ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} Ċ } Ċ