METHOD_0 ( ) { final java . util . IDENT_0 IDENT_1 = new java . util . METHOD_1 ( ) ; final org . apache . kafka . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_5 IDENT_6 = new org . apache . kafka . IDENT_2 . IDENT_3 . IDENT_4 . METHOD_2 ( ) ; final org . apache . kafka . streams . IDENT_7 . IDENT_4 . IDENT_8 < java . lang . Integer > IDENT_9 = new org . apache . kafka . streams . IDENT_7 . METHOD_3 ( IDENT_10 ) ; final org . apache . kafka . streams . IDENT_7 . IDENT_4 . IDENT_11 < java . lang . Integer , java . lang . String > IDENT_12 = new org . apache . kafka . streams . IDENT_7 . IDENT_4 . METHOD_4 ( IDENT_9 ) ; for ( int k = 0 ; k < 10 ; k ++ ) { final java . lang . Integer key = IDENT_1 . METHOD_5 ( ) ; final byte [ ] IDENT_13 = IDENT_10 . serialize ( IDENT_14 , key ) ; final java . lang . String value = key . toString ( ) ; final byte [ ] IDENT_15 = IDENT_16 . serialize ( IDENT_14 , value ) ; final java . lang . Integer expected = IDENT_6 . METHOD_6 ( STRING_0 , key , IDENT_13 , value , IDENT_15 , cluster ) ; for ( int IDENT_17 = 1 ; IDENT_17 < 10 ; IDENT_17 ++ ) { final org . apache . kafka . streams . IDENT_7 . IDENT_4 . IDENT_18 IDENT_19 = new org . apache . kafka . streams . IDENT_7 . IDENT_4 . METHOD_7 ( ( 10 * IDENT_17 ) , ( 20 * IDENT_17 ) ) ; final org . apache . kafka . streams . IDENT_7 . IDENT_20 < java . lang . Integer > IDENT_21 = new org . apache . kafka . streams . IDENT_7 . METHOD_8 ( key , IDENT_19 ) ; final java . lang . Integer actual = IDENT_12 . METHOD_6 ( IDENT_14 , IDENT_21 , value , IDENT_22 . size ( ) ) ; "<AssertPlaceHolder>" ; } } IDENT_6 . close ( ) ; } size ( ) { return ( headers ) == null ? 0 : headers . size ( ) ; }
org . junit . Assert . assertEquals ( expected , actual )