METHOD_0 ( ) { org . apache . kafka . common . header . IDENT_0 [ ] headers = new org . apache . kafka . common . header . IDENT_0 [ ] { new org . apache . kafka . common . header . IDENT_1 . METHOD_1 ( "foo" , "value" . getBytes ( ) ) , new org . apache . kafka . common . header . IDENT_1 . METHOD_1 ( "bar" , ( ( byte [ ] ) ( null ) ) ) , new org . apache . kafka . common . header . IDENT_1 . METHOD_1 ( STRING_0 , "value" . getBytes ( ) ) } ; org . apache . kafka . common . record . IDENT_2 record = new org . apache . kafka . common . record . METHOD_2 ( INT_0 , STRING_1 . getBytes ( ) , STRING_2 . getBytes ( ) , headers ) ; int IDENT_3 = INT_1 ; long IDENT_4 = INT_2 ; int IDENT_5 = 10 ; long IDENT_6 = java . lang . System . currentTimeMillis ( ) ; long IDENT_7 = INT_3 ; org . apache . kafka . common . utils . IDENT_8 out = new org . apache . kafka . common . utils . METHOD_3 ( INT_4 ) ; org . apache . kafka . common . record . IDENT_9 . METHOD_4 ( new java . io . METHOD_5 ( out ) , IDENT_5 , IDENT_7 , record . key ( ) , record . value ( ) , record . headers ( ) ) ; java . nio . ByteBuffer buffer = out . buffer ( ) ; buffer . METHOD_6 ( ) ; buffer . put ( INT_5 , ( ( byte ) ( 4 ) ) ) ; org . apache . kafka . common . record . IDENT_9 IDENT_10 = org . apache . kafka . common . record . IDENT_9 . METHOD_7 ( buffer , IDENT_4 , IDENT_6 , IDENT_3 , null ) ; "<AssertPlaceHolder>" ; } METHOD_8 ( int , long , java . nio . ByteBuffer , java . nio . ByteBuffer , org . apache . kafka . common . header . IDENT_0 [ ] ) { int IDENT_11 = org . apache . kafka . common . record . IDENT_9 . METHOD_9 ( IDENT_5 , IDENT_7 , key , value , headers ) ; return IDENT_11 + ( org . apache . kafka . common . utils . IDENT_12 . METHOD_10 ( IDENT_11 ) ) ; }
org . junit . Assert . assertEquals ( org . apache . kafka . common . record . IDENT_9 . METHOD_8 ( IDENT_5 , IDENT_7 , record . key ( ) , record . value ( ) , record . headers ( ) ) , IDENT_10 . METHOD_8 ( ) )