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