METHOD_0 ( ) { final org . apache . kafka . streams . IDENT_0 . IDENT_1 < java . lang . Integer > IDENT_2 = new org . apache . kafka . streams . IDENT_0 . METHOD_1 ( 10 , new org . apache . kafka . streams . IDENT_0 . IDENT_3 . METHOD_2 ( 0 , 1 ) ) ; final org . apache . kafka . common . serialization . IDENT_4 < org . apache . kafka . streams . IDENT_0 . METHOD_1 < java . lang . Integer > > IDENT_5 = org . apache . kafka . streams . IDENT_0 . IDENT_6 . METHOD_3 ( org . apache . kafka . streams . IDENT_0 . Integer . class ) ; final byte [ ] bytes = IDENT_5 . serializer ( ) . serialize ( IDENT_7 , IDENT_2 ) ; final org . apache . kafka . streams . IDENT_0 . METHOD_1 < java . lang . Integer > IDENT_8 = IDENT_5 . METHOD_4 ( ) . METHOD_5 ( IDENT_7 , bytes ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( java . lang . String , byte [ ] ) { if ( ( ( ( i ) ++ ) OP_0 2 ) == 1 ) { org . junit . Assert . assertEquals ( STRING_0 , new java . lang . String ( data , java . nio . IDENT_9 . IDENT_10 . UTF_8 ) ) ; throw new org . apache . kafka . common . errors . METHOD_6 ( ) ; } return data ; }
org . junit . Assert . assertEquals ( IDENT_2 , IDENT_8 )