package Ġno . nav . sy fo . slow tests . kafka Ċ Ċ import Ġcom . fasterxml . jackson . databind . Deserialization Feature Ċ import Ġcom . fasterxml . jackson . databind . Mapper Feature Ċ import Ġcom . fasterxml . jackson . databind . ObjectMapper Ċ import Ġcom . fasterxml . jackson . databind . Serialization Feature Ċ import Ġcom . fasterxml . jackson . datatype . jdk 8 . J dk 8 Module Ċ import Ġcom . fasterxml . jackson . datatype . js r 3 1 0 . Java Time Module Ċ import Ġcom . fasterxml . jackson . module . kotlin . Kotlin Module Ċ import Ġno . nav . sy fo . integration . kafka . U ts att Opp g ave Kafka Client Ċ import Ġno . nav . sy fo . integration . kafka . jo ark Local Properties Ċ import Ġno . nav . sy fo . integration . kafka . producer Local Properties Ċ import Ġno . nav . sy fo . integration . kafka . uts att Opp g ave Local Properties Ċ import Ġno . nav . sy fo . slow tests . System TestBase Ċ import Ġno . nav . sy fo . uts att Opp g ave K aka Data Ċ import Ġorg . assertj . core . api . Assertions Ċ import Ġorg . junit . jupiter . api . After All Ċ import Ġorg . junit . jupiter . api . Before All Ċ import Ġorg . junit . jupiter . api . Test Ċ Ċ class ĠU ts att Opp g ave Kafka Consumer Test Ġ: ĠSystem TestBase () Ġ{ ĊĠĠĠ Ġprivate Ġlateinit Ġvar Ġkafka Prod us ent : ĠKafka Admin For Tests ĊĠĠĠ Ġprivate Ġval Ġtopic Name Ġ= Ġ" topic " ĊĠĠĠ Ġprivate Ġval ĠobjectMapper Ġ= ĠObjectMapper () ĊĠĠĠĠĠĠĠ Ġ. register Module ( Kotlin Module ()) ĊĠĠĠĠĠĠĠ Ġ. register Module ( J dk 8 Module ()) ĊĠĠĠĠĠĠĠ Ġ. register Module ( Java Time Module ()) ĊĠĠĠĠĠĠĠ Ġ. disable ( Serialization Feature . WRITE _ DAT ES _ AS _ TIMESTAMP S ) ĊĠĠĠĠĠĠĠ Ġ. configure ( Serialization Feature . IND ENT _ OUTPUT , Ġtrue ) ĊĠĠĠĠĠĠĠ Ġ. configure ( Mapper Feature . ACCEPT _ CASE _ INS ENS ITIVE _ PROPERTIES , Ġtrue ) ĊĠĠĠĠĠĠĠ Ġ. configure ( Deserialization Feature . FAIL _ ON _ UNKNOWN _ PROPERTIES , Ġfalse ) ĊĊĠĠĠ Ġprivate Ġval Ġut s att meld ing Consumer Ġ= ĠU ts att Opp g ave Kafka Client ( ĊĠĠĠĠĠĠĠ Ġut s att Opp g ave Local Properties (). to Mutable Map (), ĊĠĠĠĠĠĠĠ Ġtopic Name ĊĠĠĠ Ġ) ĊĊĠĠĠ Ġ@ Before All ĊĠĠĠ Ġinternal Ġfun ĠsetUp () Ġ{ ĊĠĠĠĠĠĠĠ Ġkafka Prod us ent Ġ= ĠKafka Admin For Tests ( uts att Opp g ave Local Properties (). to Mutable Map (), Ġtopic Name ) ĊĠĠĠĠĠĠĠ Ġkafka Prod us ent Ġ= ĠKafka Admin For Tests ( jo ark Local Properties (). to Mutable Map (), Ġtopic Name ) ĊĠĠĠĠĠĠĠ Ġkafka Prod us ent . create Topic IfNot Exists () ĊĠĠĠĠĠĠĠ Ġkafka Prod us ent . add Re cor de To Kafka ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠobjectMapper . writeValue AsString ( uts att Opp g ave K aka Data ), ĊĠĠĠĠĠĠĠĠĠĠĠ Ġtopic Name , ĊĠĠĠĠĠĠĠĠĠĠĠ Ġproducer Local Properties (" localhost : 9 0 9 2 ") ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ After All ĊĠĠĠ Ġinternal Ġfun ĠtearDown () Ġ{ ĊĠĠĠĠĠĠĠ Ġkafka Prod us ent . delete Topic And Close Connection () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġ` Sk al Ġle se Ġut sat to pp g ave `() Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġme ld inger Ġ= Ġut s att meld ing Consumer . get Messages To Process () ĊĠĠĠĠĠĠĠ ĠAssertions . assertThat ( meld inger . size ). isEqualTo ( 1 ) ĊĠĠĠĠĠĠĠ ĠAssertions . assertThat ( meld inger [ 0 ]). isEqualTo ( object Mapper . writeValue AsString ( uts att Opp g ave K aka Data )) ĊĠĠĠ Ġ} Ċ } Ċ