METHOD_0 ( ) { final java . lang . Long IDENT_0 = java . lang . System . currentTimeMillis ( ) ; METHOD_1 ( ) ; java . util . List < org . apache . kafka . connect . source . IDENT_1 > records = java . util . Collections . singletonList ( new org . apache . kafka . connect . source . METHOD_2 ( org . apache . kafka . connect . runtime . IDENT_2 . IDENT_3 , org . apache . kafka . connect . runtime . IDENT_2 . IDENT_4 , STRING_0 , null , org . apache . kafka . connect . runtime . IDENT_2 . IDENT_5 , org . apache . kafka . connect . runtime . IDENT_2 . IDENT_6 , org . apache . kafka . connect . runtime . IDENT_2 . IDENT_7 , org . apache . kafka . connect . runtime . IDENT_2 . IDENT_8 , IDENT_0 ) ) ; org . easymock . IDENT_9 < org . apache . kafka . IDENT_10 . IDENT_11 . IDENT_12 < byte [ ] , byte [ ] > > IDENT_13 = METHOD_3 ( ) ; org . IDENT_14 . api . easymock . IDENT_15 . METHOD_4 ( ) ; org . IDENT_14 . reflect . IDENT_16 . METHOD_5 ( IDENT_17 , STRING_1 , records ) ; org . IDENT_14 . reflect . IDENT_16 . METHOD_6 ( IDENT_17 , STRING_2 ) ; "<AssertPlaceHolder>" ; org . IDENT_14 . api . easymock . IDENT_15 . METHOD_7 ( ) ; } getValue ( ) { return ( OP_0 ( IDENT_18 ) ) & INT_0 ; }
org . junit . Assert . assertEquals ( IDENT_0 , IDENT_13 . getValue ( ) . METHOD_8 ( ) )