METHOD_0 ( ) { byte [ ] value = new byte [ 0 ] ; org . apache . kafka . connect . util . IDENT_0 < java . lang . String , byte [ ] > IDENT_1 = mock ( org . apache . kafka . connect . util . IDENT_0 . class ) ; org . apache . kafka . connect . storage . IDENT_2 converter = mock ( org . apache . kafka . connect . storage . IDENT_2 . class ) ; org . apache . kafka . connect . storage . IDENT_3 store = new org . apache . kafka . connect . storage . METHOD_1 ( new org . apache . kafka . common . utils . METHOD_2 ( ) , converter , org . apache . kafka . connect . storage . IDENT_4 . IDENT_5 , IDENT_1 ) ; java . util . Map < java . lang . String , java . lang . Object > IDENT_6 = new java . util . HashMap ( ) ; IDENT_6 . put ( STRING_0 , org . apache . kafka . connect . storage . IDENT_4 . IDENT_7 ) ; IDENT_6 . put ( STRING_1 , STRING_2 ) ; IDENT_6 . put ( STRING_3 , 0L ) ; expect ( converter . METHOD_3 ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_5 , value ) ) . andReturn ( new org . apache . kafka . connect . data . METHOD_4 ( null , IDENT_6 ) ) ; METHOD_5 ( ) ; store . read ( org . apache . kafka . connect . storage . IDENT_4 . METHOD_6 ( 0 , STRING_4 , value ) ) ; org . apache . kafka . connect . runtime . IDENT_8 status = new org . apache . kafka . connect . runtime . METHOD_7 ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_9 , METHOD_7 . IDENT_10 . IDENT_11 , org . apache . kafka . connect . storage . IDENT_4 . IDENT_7 , 0 ) ; "<AssertPlaceHolder>" ; METHOD_8 ( ) ; } get ( org . apache . kafka . connect . data . Field ) { java . lang . Object val = values [ field . index ( ) ] ; if ( ( val == null ) && ( ( field . schema ( ) . METHOD_9 ( ) ) != null ) ) { val = field . schema ( ) . METHOD_9 ( ) ; } return val ; }
org . junit . Assert . assertEquals ( status , store . get ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_9 ) )