METHOD_0 ( ) { try { final java . lang . String IDENT_0 = STRING_0 ; final java . lang . String IDENT_1 = STRING_1 ; final java . lang . Long offset = ( ( long ) ( ( java . lang . Math . random ( ) ) * ( Long . MAX_VALUE ) ) ) ; final java . lang . Long IDENT_2 ; try ( org . apache . IDENT_3 . framework . IDENT_4 IDENT_5 = ( ( org . apache . flink . streaming . IDENT_6 . kafka . IDENT_7 ) ( IDENT_8 ) ) . METHOD_1 ( ) ) { IDENT_8 . METHOD_2 ( IDENT_0 , 3 , 2 ) ; org . apache . flink . streaming . IDENT_6 . kafka . IDENT_9 . IDENT_10 . METHOD_3 ( IDENT_5 , IDENT_1 , IDENT_0 , 0 , offset ) ; IDENT_2 = org . apache . flink . streaming . IDENT_6 . kafka . IDENT_9 . IDENT_10 . METHOD_4 ( IDENT_5 , IDENT_1 , IDENT_0 , 0 ) ; } "<AssertPlaceHolder>" ; } catch ( java . lang . Exception e ) { e . printStackTrace ( ) ; org . junit . Assert . fail ( e . getMessage ( ) ) ; } } METHOD_4 ( org . apache . IDENT_3 . framework . IDENT_4 , java . lang . String , java . lang . String , int ) { kafka . utils . IDENT_11 IDENT_12 = new kafka . utils . METHOD_5 ( IDENT_1 , IDENT_13 ) ; java . lang . String path = ( ( IDENT_12 . METHOD_6 ( ) ) + "/" ) + IDENT_14 ; IDENT_15 . METHOD_7 ( path ) . METHOD_8 ( IDENT_15 . METHOD_9 ( ) ) ; byte [ ] data = IDENT_15 . METHOD_10 ( ) . METHOD_11 ( path ) ; if ( data == null ) { return null ; } else { java . lang . String IDENT_16 = new java . lang . String ( data , org . apache . flink . configuration . IDENT_17 . IDENT_18 ) ; if ( ( IDENT_16 . length ( ) ) == 0 ) { return null ; } else { try { return java . lang . Long . valueOf ( IDENT_16 ) ; } catch ( java . lang . IDENT_19 e ) { org . apache . flink . streaming . IDENT_6 . kafka . IDENT_9 . IDENT_10 . LOG . error ( STRING_2 , IDENT_1 , IDENT_13 , IDENT_14 , IDENT_16 ) ; return null ; } } } }
org . junit . Assert . assertEquals ( offset , IDENT_2 )