METHOD_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 ) ; byte [ ] value = new byte [ 0 ] ; expect ( converter . METHOD_3 ( eq ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_5 ) , METHOD_4 ( org . apache . kafka . connect . data . Schema . class ) , METHOD_4 ( org . apache . kafka . connect . data . IDENT_6 . class ) ) ) . METHOD_5 ( value ) ; final org . easymock . IDENT_7 < org . apache . kafka . IDENT_8 . IDENT_9 . IDENT_10 > IDENT_11 = METHOD_6 ( ) ; IDENT_1 . METHOD_7 ( eq ( STRING_0 ) , eq ( value ) , METHOD_8 ( IDENT_11 ) ) ; METHOD_9 ( ) . METHOD_10 ( new org . easymock . IDENT_12 < java . lang . IDENT_13 > ( ) { @ org . apache . kafka . connect . storage . Override public org . apache . kafka . connect . storage . IDENT_13 METHOD_11 ( ) throws java . lang . Throwable { IDENT_11 . getValue ( ) . METHOD_12 ( null , new org . apache . kafka . common . errors . METHOD_13 ( ) ) ; return null ; } } ) . METHOD_10 ( new org . easymock . IDENT_12 < java . lang . IDENT_13 > ( ) { @ org . apache . kafka . connect . storage . Override public org . apache . kafka . connect . storage . IDENT_13 METHOD_11 ( ) throws java . lang . Throwable { IDENT_11 . getValue ( ) . METHOD_12 ( null , null ) ; return null ; } } ) ; METHOD_14 ( ) ; org . apache . kafka . connect . runtime . IDENT_14 status = new org . apache . kafka . connect . runtime . METHOD_15 ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_15 , METHOD_15 . IDENT_16 . IDENT_17 , org . apache . kafka . connect . storage . IDENT_4 . IDENT_18 , 0 ) ; store . put ( status ) ; "<AssertPlaceHolder>" ; METHOD_16 ( ) ; } get ( org . apache . kafka . connect . data . Field ) { java . lang . Object val = values [ field . index ( ) ] ; if ( ( val == null ) && ( ( field . schema ( ) . METHOD_17 ( ) ) != null ) ) { val = field . schema ( ) . METHOD_17 ( ) ; } return val ; }
org . junit . Assert . assertEquals ( null , store . get ( org . apache . kafka . connect . storage . IDENT_4 . IDENT_15 ) )