METHOD_0 ( ) { long IDENT_0 = INT_0 ; java . util . Properties IDENT_1 = new java . util . Properties ( ) ; IDENT_1 . setProperty ( STRING_0 , STRING_1 ) ; com . IDENT_2 . IDENT_3 . IDENT_4 . kafka . IDENT_5 . IDENT_6 IDENT_7 = new com . IDENT_2 . IDENT_3 . IDENT_4 . kafka . IDENT_5 . METHOD_1 ( ) ; IDENT_7 . init ( IDENT_1 , STRING_2 ) ; java . lang . String payload = ( STRING_3 + IDENT_0 ) + STRING_4 ; byte [ ] IDENT_8 = payload . getBytes ( ) ; com . IDENT_2 . IDENT_3 . IDENT_5 . IDENT_9 IDENT_10 = IDENT_7 . decode ( new com . IDENT_2 . IDENT_3 . IDENT_4 . kafka . IDENT_5 . METHOD_2 ( ) . METHOD_3 ( IDENT_8 ) ) ; long IDENT_11 = IDENT_10 . METHOD_4 ( ) ; "<AssertPlaceHolder>" ; } METHOD_4 ( ) { org . apache . avro . IDENT_12 . IDENT_13 . IDENT_14 header = ( ( org . apache . avro . IDENT_12 . IDENT_13 . IDENT_14 ) ( super . METHOD_5 ( ) . get ( STRING_5 ) ) ) ; if ( ( header != null ) && ( ( header . get ( STRING_6 ) ) != null ) ) { return ( ( java . lang . Long ) ( header . get ( STRING_6 ) ) ) ; } else if ( ( super . METHOD_5 ( ) . get ( STRING_7 ) ) != null ) { return ( ( java . lang . Long ) ( super . METHOD_5 ( ) . get ( STRING_7 ) ) ) ; } else { return java . lang . System . currentTimeMillis ( ) ; } }
org . junit . Assert . assertEquals ( IDENT_0 , IDENT_11 )