METHOD_0 ( ) { task = METHOD_1 ( METHOD_2 ( true ) ) ; final org . apache . kafka . streams . processor . IDENT_0 . IDENT_1 IDENT_2 = new org . apache . kafka . streams . processor . IDENT_0 . METHOD_3 ( STRING_0 , new org . apache . kafka . common . utils . METHOD_4 ( STRING_1 ) , new org . apache . kafka . streams . errors . METHOD_5 ( ) , new org . apache . kafka . common . metrics . METHOD_6 ( ) . METHOD_7 ( STRING_2 ) ) ; IDENT_2 . init ( IDENT_3 ) ; task . METHOD_8 ( ) ; task . METHOD_9 ( ) ; task . METHOD_10 ( IDENT_4 , 5 , IDENT_5 . IDENT_6 , new org . apache . kafka . streams . processor . METHOD_11 ( ) { @ org . apache . kafka . streams . processor . IDENT_0 . Override public void METHOD_10 ( final long IDENT_7 ) { IDENT_2 . METHOD_12 ( STRING_3 , 3 , 5 , null , 0 , time . METHOD_13 ( ) , new org . apache . kafka . common . serialization . METHOD_14 ( ) , new org . apache . kafka . common . serialization . METHOD_14 ( ) ) ; } } ) ; task . commit ( ) ; "<AssertPlaceHolder>" ; } METHOD_15 ( ) { return new java . util . ArrayList ( this . IDENT_8 ) ; }
org . junit . Assert . assertEquals ( 1 , IDENT_3 . METHOD_15 ( ) . size ( ) )