METHOD_0 ( ) { final org . IDENT_0 . IDENT_1 . IDENT_2 IDENT_3 = new org . IDENT_0 . IDENT_1 . METHOD_1 ( IDENT_4 , INT_0 , INT_0 , new io . IDENT_5 . kafka . IDENT_6 . storage . serialization . METHOD_2 ( ) ) ; int IDENT_7 = ( io . IDENT_5 . kafka . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 ) - 1 ; io . IDENT_5 . common . utils . IDENT_9 . IDENT_12 . METHOD_3 ( IDENT_3 , io . IDENT_5 . kafka . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_13 , ( "" + IDENT_7 ) ) ; final io . IDENT_5 . kafka . IDENT_6 . IDENT_14 IDENT_15 = new io . IDENT_5 . kafka . IDENT_6 . METHOD_4 ( METHOD_5 ( ) , IDENT_4 , IDENT_16 ) ; IDENT_15 . start ( ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( org . IDENT_0 . IDENT_1 . METHOD_1 ) { return java . lang . Integer . valueOf ( io . IDENT_5 . common . utils . IDENT_9 . IDENT_12 . METHOD_7 ( IDENT_3 , io . IDENT_5 . kafka . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_13 ) . METHOD_8 ( ) ) ; }
org . junit . Assert . assertEquals ( "" , ( 2 * ( io . IDENT_5 . kafka . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . IDENT_11 ) ) , io . IDENT_5 . kafka . IDENT_6 . IDENT_8 . IDENT_9 . IDENT_10 . METHOD_6 ( IDENT_3 ) )