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