METHOD_0 ( ) { final org . apache . kafka . streams . processor . IDENT_0 IDENT_1 = new org . apache . kafka . streams . processor . METHOD_1 ( ) ; final java . util . Map < org . apache . kafka . streams . processor . IDENT_2 , java . util . Set < org . apache . kafka . common . IDENT_3 > > IDENT_4 = new java . util . HashMap ( ) ; final java . util . Map < java . lang . Integer , java . util . Set < java . lang . String > > IDENT_5 = new java . util . HashMap ( ) ; int IDENT_6 = 0 ; IDENT_5 . put ( IDENT_6 , METHOD_2 ( STRING_0 ) ) ; IDENT_4 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , 0 ) , METHOD_2 ( new org . apache . kafka . common . METHOD_4 ( STRING_0 , 0 ) ) ) ; IDENT_4 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , 1 ) , METHOD_2 ( new org . apache . kafka . common . METHOD_4 ( STRING_0 , 1 ) ) ) ; IDENT_4 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , 2 ) , METHOD_2 ( new org . apache . kafka . common . METHOD_4 ( STRING_0 , 2 ) ) ) ; IDENT_5 . put ( ( ++ IDENT_6 ) , METHOD_2 ( STRING_1 ) ) ; IDENT_4 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , 0 ) , METHOD_2 ( new org . apache . kafka . common . METHOD_4 ( STRING_1 , 0 ) ) ) ; IDENT_4 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , 1 ) , METHOD_2 ( new org . apache . kafka . common . METHOD_4 ( STRING_1 , 1 ) ) ) ; "<AssertPlaceHolder>" ; } METHOD_5 ( java . util . Map , org . apache . kafka . common . IDENT_7 ) { final java . util . Map < org . apache . kafka . streams . processor . METHOD_3 , java . util . Set < org . apache . kafka . common . METHOD_4 > > IDENT_8 = new java . util . HashMap ( ) ; for ( final Map . Entry < java . lang . Integer , java . util . Set < java . lang . String > > entry : IDENT_5 . entrySet ( ) ) { final java . lang . Integer IDENT_6 = entry . getKey ( ) ; final java . util . Set < java . lang . String > IDENT_9 = entry . getValue ( ) ; final int IDENT_10 = METHOD_6 ( metadata , IDENT_9 ) ; for ( int IDENT_11 = 0 ; IDENT_11 < METHOD_6 ; IDENT_11 ++ ) { final java . util . Set < org . apache . kafka . common . METHOD_4 > group = new java . util . HashSet ( IDENT_9 . size ( ) ) ; for ( final java . lang . String IDENT_12 : IDENT_9 ) { final java . util . List < org . apache . kafka . common . IDENT_13 > IDENT_14 = metadata . METHOD_7 ( IDENT_12 ) ; if ( IDENT_11 < ( IDENT_14 . size ( ) ) ) { group . add ( new org . apache . kafka . common . METHOD_4 ( IDENT_12 , IDENT_11 ) ) ; } } IDENT_8 . put ( new org . apache . kafka . streams . processor . METHOD_3 ( IDENT_6 , IDENT_11 ) , java . util . Collections . METHOD_8 ( group ) ) ; } } return java . util . Collections . METHOD_9 ( IDENT_8 ) ; }
org . junit . Assert . assertEquals ( IDENT_4 , IDENT_1 . METHOD_5 ( IDENT_5 , metadata ) )