package Ġcom . github . wp an as . spring . kafka Ċ Ċ import Ġorg . apache . kafka . clients . consumer . Consumer Record Ċ import Ġorg . junit . jupiter . api . Assertions . assertNotNull Ċ import Ġorg . junit . jupiter . api . Assertions . assertTrue Ċ import Ġorg . junit . jupiter . api . Test Ċ import Ġorg . springframework . beans . factory . annotation . Autowired Ċ import Ġorg . springframework . boot . test . context . SpringBootTest Ċ import Ġorg . springframework . test . context . Context Configuration Ċ Ċ @ SpringBootTest ( properties Ġ= Ġ[" order - processor . enabled = false "]) Ċ @ Context Configuration ( initial izers Ġ= Ġ[ Kafka Initializer :: class ]) Ċ internal Ġclass ĠOrder Processor Test Ġ{ ĊĊĠĠĠ Ġ@ Autowired ĊĠĠĠ Ġlateinit Ġvar Ġunder Test : ĠOrder Processor ĊĊĠĠĠ Ġ@ Autowired ĊĠĠĠ Ġlateinit Ġvar Ġorder Service : ĠOrder Service ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġinternal Ġfun Ġ` should Ġprocess Ġorders `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġdetails Ġ= ĠOrder Details (" Lat te ") ĊĠĠĠĠĠĠĠ Ġval ĠorderId Ġ= Ġorder Service . place Order ( details ). id ĊĊĠĠĠĠĠĠĠ Ġunder Test . on Message ( Consumer Record ( topic , Ġ 0 , Ġ 0 , ĠorderId . toString (), Ġdetails )) ĊĊĠĠĠĠĠĠĠ Ġval Ġorder Ġ= Ġorder Service . findOne ( orderId ) ĊĊĠĠĠĠĠĠĠ ĠassertNotNull ( order ) ĊĠĠĠĠĠĠĠ ĠassertTrue ( order ?. is Done !! ) ĊĠĠĠ Ġ} Ċ } Ċ