package Ġcompany . e vo . kafka Ċ Ċ import Ġorg . apache . kafka . common . config . Config Exception Ċ import Ġorg . apache . kafka . connect . errors . DataException Ċ Ċ import Ġorg . assertj . core . api . Assertions .* Ċ Ċ import Ġorg . junit . jupiter . api . Test Ċ import Ġorg . junit . jupiter . api . BeforeEach Ċ Ċ import Ġcompany . e vo . kafka . Test Proto . Test Document Ċ import Ġorg . apache . kafka . connect . data . Schema And Value ĊĊ Ċ class ĠProtobuf Converter Tests Ġ{ ĊĠĠĠ Ġprivate Ġval Ġconverter Ġ= ĠProtobuf Converter () ĊĠĠĠ Ġprivate Ġval Ġtest Msg Ġ= ĠTest Document . newBuilder () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. setId ( 1 2 3 ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. setName (" Te o ") ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. build () ĊĊĠĠĠ Ġ@ BeforeEach ĊĠĠĠ Ġfun Ġconfigure Converter () Ġ{ ĊĠĠĠĠĠĠĠ Ġconverter . configure ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmutable Map Of (" protobuf . class " Ġto Ġ" company . e vo . kafka . Test Proto \$ Test Document "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfalse ĊĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Required Configuration () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat Thrown By Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconverter . configure ( mutable Map Of < String , ĠAny >(), Ġfalse ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isInstanceOf ( Config Exception :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. has Message Starting With ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Missing Ġrequired Ġconfiguration Ġ\" protobuf . class \" ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Missing Protobuf Class () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat Thrown By Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconverter . configure ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmutable Map Of (" protobuf . class " Ġto Ġ" company . e vo . kafka . Unknown Message "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfalse ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isInstanceOf ( Config Exception :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. has Message Containing ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Class Ġcompany . e vo . kafka . Unknown Message Ġcould Ġnot Ġbe Ġfound ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Invalid Protobuf Class () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat Thrown By Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconverter . configure ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġmutable Map Of (" protobuf . class " Ġto Ġ" company . e vo . kafka . Protobuf Converter "), ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġfalse ) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isInstanceOf ( Config Exception :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. has Message Containing ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" company . e vo . kafka . Protobuf Converter Ġclass Ġhas Ġno Ġmethod ĠparseFrom ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest To Connect Data () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġdata Ġ= Ġtest Msg . toByteArray () ĊĠĠĠĠĠĠĠ Ġval Ġschema And Value Ġ= Ġconverter . to Connect Data ("< test >", Ġdata ) ĊĠĠĠĠĠĠĠ ĠassertThat ( schema And Value . schema ()). isNull () ĊĠĠĠĠĠĠĠ Ġval Ġvalue Ġ= Ġschema And Value . value () ĊĠĠĠĠĠĠĠ Ġif Ġ( value Ġ! is ĠTest Document ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġthrow ĠAssertionError ("$ value Ġmust Ġbe Ġan Ġinstance Ġof Ġ${ Test Document :: class . java }") ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ ĠassertThat ( value . id ). isEqualTo ( 1 2 3 ) ĊĠĠĠĠĠĠĠ ĠassertThat ( value . name ). isEqualTo (" Te o ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest To Connect Data NullValue () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat ( converter . to Connect Data ("< test >", Ġnull )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isEqualTo ( Schema And Value . NULL ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest To Connect Data Invalid Data () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat Thrown By Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconverter . to Connect Data ("< test >", Ġ" invalid Ġdata ". toByteArray ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isInstanceOf ( DataException :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. has Message Starting With (" Cannot Ġdeserialize Ġdata ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest From Connect Data () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġdata Ġ= Ġconverter . from Connect Data ("< test >", Ġnull , Ġtest Msg ) ĊĠĠĠĠĠĠĠ Ġval Ġvalue Ġ= ĠTest Document . parseFrom ( data ) ĊĠĠĠĠĠĠĠ ĠassertThat ( value . id ). isEqualTo ( 1 2 3 ) ĊĠĠĠĠĠĠĠ ĠassertThat ( value . name ). isEqualTo (" Te o ") ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest From Connect Data NullValue () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat ( converter . from Connect Data ("< test >", Ġnull , Ġnull )) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isNull () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest From Connect Data Invalid Message () Ġ{ ĊĠĠĠĠĠĠĠ ĠassertThat Thrown By Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġconverter . from Connect Data ("< test >", Ġnull , ĠObject ()) ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. isInstanceOf ( DataException :: class . java ) ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ. has Message Starting With ( ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ" Value Ġmust Ġbe Ġinstance Ġof Ġcom . google . protobuf . Message Lite " ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġ) ĊĠĠĠ Ġ} Ċ }