METHOD_0 ( ) { java . util . List < java . lang . Object > IDENT_0 = new java . util . ArrayList < java . lang . Object > ( ) ; org . apache . hadoop . conf . Configuration configuration = org . easymock . EasyMock . METHOD_1 ( org . apache . hadoop . conf . Configuration . class ) ; IDENT_0 . add ( configuration ) ; org . easymock . EasyMock . expect ( configuration . get ( org . easymock . EasyMock . anyString ( ) ) ) . andReturn ( com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_6 ) . METHOD_2 ( ) ; org . apache . hadoop . mapreduce . IDENT_7 IDENT_8 = org . easymock . EasyMock . METHOD_1 ( org . apache . hadoop . mapreduce . IDENT_7 . class ) ; IDENT_0 . add ( IDENT_8 ) ; org . easymock . EasyMock . expect ( IDENT_8 . METHOD_3 ( ) ) . andReturn ( configuration ) . METHOD_2 ( ) ; java . util . List < kafka . IDENT_9 . IDENT_10 > IDENT_11 = new java . util . ArrayList < kafka . IDENT_9 . IDENT_10 > ( ) ; kafka . IDENT_9 . IDENT_12 IDENT_13 = org . easymock . EasyMock . METHOD_1 ( kafka . IDENT_9 . IDENT_12 . class ) ; IDENT_0 . add ( IDENT_13 ) ; org . easymock . EasyMock . expect ( IDENT_13 . METHOD_4 ( ) ) . andReturn ( IDENT_11 ) ; kafka . IDENT_9 . consumer . IDENT_14 IDENT_15 = org . easymock . EasyMock . METHOD_1 ( kafka . IDENT_9 . consumer . IDENT_14 . class ) ; IDENT_0 . add ( IDENT_15 ) ; org . easymock . EasyMock . expect ( IDENT_15 . METHOD_5 ( ) ) . andReturn ( com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_5 . IDENT_6 ) . times ( 2 ) ; org . easymock . EasyMock . expect ( IDENT_15 . METHOD_6 ( ( ( kafka . IDENT_9 . IDENT_16 ) ( org . easymock . EasyMock . METHOD_7 ( ) ) ) ) ) . METHOD_8 ( new java . lang . RuntimeException ( STRING_0 ) ) ; org . easymock . EasyMock . expect ( IDENT_15 . METHOD_6 ( ( ( kafka . IDENT_9 . IDENT_16 ) ( org . easymock . EasyMock . METHOD_7 ( ) ) ) ) ) . andReturn ( IDENT_13 ) ; IDENT_15 . close ( ) ; org . easymock . EasyMock . METHOD_9 ( ) . METHOD_10 ( ) . METHOD_2 ( ) ; org . easymock . EasyMock . replay ( IDENT_0 . toArray ( ) ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_17 IDENT_18 = new com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . METHOD_11 ( ) ; METHOD_11 . IDENT_19 = METHOD_11 . IDENT_20 . IDENT_21 ; METHOD_11 . consumer = IDENT_15 ; java . util . List < kafka . IDENT_9 . IDENT_10 > IDENT_22 = IDENT_18 . METHOD_12 ( IDENT_8 , new java . util . ArrayList < java . lang . String > ( ) ) ; org . easymock . EasyMock . verify ( IDENT_0 . toArray ( ) ) ; "<AssertPlaceHolder>" ; } METHOD_12 ( org . apache . hadoop . mapreduce . IDENT_7 , java . util . List ) { com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_23 . METHOD_13 ( STRING_1 ) ; java . lang . String IDENT_24 = com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_23 . METHOD_14 ( context ) ; if ( IDENT_24 . isEmpty ( ) ) throw new java . security . METHOD_15 ( STRING_2 ) ; java . util . List < java . lang . String > IDENT_25 = java . util . Arrays . asList ( IDENT_24 . split ( STRING_3 ) ) ; java . util . Collections . METHOD_16 ( IDENT_25 ) ; boolean IDENT_26 = false ; int i = 0 ; java . util . List < kafka . IDENT_9 . IDENT_10 > IDENT_27 = null ; java . lang . Exception IDENT_28 = null ; while ( ( i < ( IDENT_25 . size ( ) ) ) && ( ! IDENT_26 ) ) { kafka . IDENT_9 . consumer . IDENT_14 consumer = METHOD_17 ( context , IDENT_25 . get ( i ) ) ; com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_17 . log . info ( java . lang . String . format ( STRING_4 , IDENT_25 . get ( i ) , consumer . METHOD_5 ( ) , IDENT_29 . size ( ) , IDENT_29 ) ) ; try { for ( int IDENT_30 = 0 ; IDENT_30 < ( com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_17 . IDENT_31 ) ; IDENT_30 ++ ) { try { IDENT_27 = consumer . METHOD_6 ( new kafka . IDENT_9 . METHOD_18 ( IDENT_29 ) ) . METHOD_4 ( ) ; IDENT_26 = true ; break ; } catch ( java . lang . Exception e ) { IDENT_28 = e ; com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_17 . log . warn ( java . lang . String . format ( STRING_5 , consumer . METHOD_5 ( ) , IDENT_29 , IDENT_25 . get ( i ) , IDENT_30 ) , e ) ; try { java . lang . Thread . sleep ( ( ( long ) ( ( ( java . lang . Math . random ( ) ) * ( IDENT_30 + 1 ) ) * 1000 ) ) ) ; } catch ( java . lang . IDENT_32 ex ) { com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_4 . IDENT_17 . log . warn ( ( STRING_6 + ex ) ) ; } } } } finally { consumer . close ( ) ; i ++ ; } } if ( ! IDENT_26 ) { throw new java . lang . RuntimeException ( STRING_7 , IDENT_28 ) ; } com . IDENT_1 . IDENT_2 . IDENT_3 . kafka . IDENT_23 . METHOD_19 ( STRING_1 ) ; return IDENT_27 ; }
org . junit . Assert . assertEquals ( IDENT_22 , IDENT_11 )