METHOD_0 ( ) { Type . String path = getClass ( ) . getResource ( STRING_0 4 ) . getPath ( ) ; org . pentaho . di . IDENT_0 . IDENT_1 IDENT_2 = new org . pentaho . di . IDENT_0 . METHOD_1 ( path , new org . pentaho . di . core . IDENT_3 . METHOD_2 ( ) ) ; org . pentaho . di . IDENT_0 . IDENT_4 IDENT_0 = new org . pentaho . di . IDENT_0 . METHOD_3 ( IDENT_2 ) ; org . pentaho . IDENT_5 . data . IDENT_6 . plugins . kafka . IDENT_7 IDENT_8 = ( ( org . pentaho . IDENT_5 . data . IDENT_6 . plugins . kafka . IDENT_7 ) ( IDENT_2 . METHOD_4 ( 0 ) . METHOD_5 ( ) ) ) ; IDENT_8 . METHOD_6 ( getClass ( ) . getResource ( STRING_1 ) . getPath ( ) ) ; IDENT_8 . METHOD_7 ( STRING_0 2 ) ; IDENT_8 . METHOD_8 ( factory ) ; IDENT_8 . METHOD_9 ( STRING_2 ) ; IDENT_8 . METHOD_10 ( false ) ; int IDENT_9 = 4 ; messages . put ( IDENT_10 , METHOD_11 ( IDENT_10 . METHOD_12 ( ) , IDENT_9 ) ) ; records = new org . apache . kafka . IDENT_11 . consumer . METHOD_13 ( messages ) ; when ( consumer . METHOD_14 ( 1000 ) ) . thenReturn ( records ) . METHOD_15 ( ( IDENT_12 ) -> { while ( ( IDENT_0 . METHOD_16 ( ) . get ( 0 ) . IDENT_13 . METHOD_17 ( ) ) < 4 ) { continue ; } IDENT_0 . METHOD_18 ( ) ; return new org . pentaho . IDENT_5 . data . IDENT_6 . plugins . kafka . METHOD_13 < > ( java . util . Collections . METHOD_19 ( ) ) ; } ) ; when ( factory . consumer ( eq ( IDENT_8 ) , any ( ) , eq ( Type . String ) , eq ( Type . String ) ) ) . thenReturn ( consumer ) ; IDENT_0 . METHOD_20 ( new Type . String [ ] { } ) ; IDENT_0 . METHOD_21 ( ) ; IDENT_0 . METHOD_22 ( ) ; METHOD_23 ( STRING_0 , STRING_3 , STRING_4 , STRING_0 1 , times ( 1 ) ) ; METHOD_23 ( STRING_0 3 , STRING_5 , STRING_0 1 , STRING_0 2 , times ( 1 ) ) ; METHOD_23 ( STRING_6 , STRING_7 , STRING_0 2 , STRING_0 1 , times ( 1 ) ) ; METHOD_23 ( STRING_8 , STRING_9 , STRING_0 0 , STRING_0 2 , times ( 1 ) ) ; "<AssertPlaceHolder>" ; java . util . Map < org . apache . kafka . common . IDENT_14 , org . apache . kafka . IDENT_11 . consumer . IDENT_15 > map = new java . util . HashMap ( ) ; map . put ( METHOD_12 , new org . apache . kafka . IDENT_11 . consumer . METHOD_24 ( 2 ) ) ; verify ( consumer ) . METHOD_25 ( map ) ; map . put ( METHOD_12 , new org . apache . kafka . IDENT_11 . consumer . METHOD_24 ( 4 ) ) ; verify ( consumer ) . METHOD_25 ( map ) ; } METHOD_16 ( ) { com . amazonaws . services . IDENT_16 . model . IDENT_17 IDENT_18 = new com . amazonaws . services . IDENT_16 . model . METHOD_26 ( ) ; IDENT_18 . METHOD_27 ( IDENT_19 ) ; com . amazonaws . services . IDENT_16 . model . IDENT_20 IDENT_21 = IDENT_22 . METHOD_28 ( IDENT_18 ) ; java . util . List < com . amazonaws . services . IDENT_16 . model . IDENT_23 > IDENT_24 = IDENT_21 . METHOD_16 ( ) ; if ( IDENT_24 . isEmpty ( ) ) { return null ; } return IDENT_24 ; }
org . junit . Assert . assertEquals ( 4 , IDENT_0 . METHOD_16 ( ) . get ( 0 ) . IDENT_13 . METHOD_17 ( ) )