METHOD_0 ( ) { final io . IDENT_0 . IDENT_1 . rest . entity . IDENT_2 IDENT_3 = new io . IDENT_0 . IDENT_1 . rest . entity . METHOD_1 ( "1" , STRING_0 , STRING_1 ) ; METHOD_2 ( IDENT_3 ) ; final io . IDENT_0 . IDENT_1 . rest . client . IDENT_4 < io . IDENT_0 . IDENT_1 . rest . entity . METHOD_1 > response = IDENT_5 . METHOD_3 ( ) ; "<AssertPlaceHolder>" ; } get ( ) { final org . apache . kafka . connect . data . IDENT_6 msg = IDENT_7 . apply ( config ) ; if ( msg . schema ( ) . equals ( IDENT_8 . IDENT_9 ) ) { return msg ; } throw new java . lang . RuntimeException ( STRING_2 ) ; }
org . junit . Assert . assertThat ( response . get ( ) , org . hamcrest . Matchers . is ( IDENT_3 ) )