METHOD_0 ( ) { org . pentaho . IDENT_0 . data . api . cluster . IDENT_1 IDENT_2 = mock ( org . pentaho . IDENT_0 . data . api . cluster . IDENT_1 . class ) ; when ( IDENT_2 . METHOD_1 ( ) ) . thenReturn ( STRING_0 ) ; org . pentaho . IDENT_0 . data . api . cluster . IDENT_3 IDENT_4 = mock ( org . pentaho . IDENT_0 . data . api . cluster . IDENT_3 . class ) ; when ( IDENT_4 . METHOD_2 ( eq ( STRING_1 ) , any ( org . pentaho . IDENT_5 . api . IDENT_6 . class ) ) ) . thenReturn ( IDENT_2 ) ; org . pentaho . IDENT_0 . data . IDENT_7 . plugins . kafka . IDENT_8 meta = new org . pentaho . IDENT_0 . data . IDENT_7 . plugins . kafka . METHOD_3 ( ) ; meta . METHOD_4 ( IDENT_9 . IDENT_10 ) ; meta . METHOD_5 ( IDENT_4 ) ; meta . METHOD_6 ( IDENT_11 ) ; meta . METHOD_7 ( STRING_2 ) ; org . pentaho . di . IDENT_12 . IDENT_13 IDENT_14 = mock ( org . pentaho . di . IDENT_12 . IDENT_13 . class ) ; when ( IDENT_14 . METHOD_8 ( STRING_2 ) ) . thenReturn ( STRING_1 ) ; org . pentaho . di . IDENT_12 . IDENT_15 . IDENT_16 IDENT_17 = new org . pentaho . di . IDENT_12 . IDENT_15 . METHOD_9 ( ) ; IDENT_17 . METHOD_10 ( IDENT_14 ) ; meta . METHOD_11 ( IDENT_17 ) ; "<AssertPlaceHolder>" ; } METHOD_12 ( ) { if ( org . pentaho . IDENT_0 . data . IDENT_7 . plugins . kafka . METHOD_3 . IDENT_9 . IDENT_18 . equals ( METHOD_13 ( ) ) ) { return METHOD_14 ( ) ; } org . pentaho . IDENT_5 . api . IDENT_6 IDENT_5 = IDENT_11 . METHOD_15 ( ) ; if ( IDENT_5 == null ) { IDENT_5 = METHOD_16 ( ) . METHOD_17 ( ) . METHOD_18 ( ) ; } java . util . Optional < org . pentaho . IDENT_0 . data . api . cluster . IDENT_1 > IDENT_19 = java . util . Optional . METHOD_19 ( IDENT_4 . METHOD_2 ( IDENT_20 . METHOD_17 ( ) . METHOD_8 ( IDENT_21 ) , IDENT_5 ) ) ; if ( ! ( IDENT_19 . METHOD_20 ( ) ) ) { IDENT_19 = java . util . Optional . METHOD_19 ( IDENT_4 . METHOD_2 ( IDENT_20 . METHOD_17 ( ) . METHOD_8 ( IDENT_21 ) , METHOD_16 ( ) . METHOD_17 ( ) . METHOD_18 ( ) ) ) ; } return IDENT_19 . map ( IDENT_1 :: METHOD_1 ) . METHOD_21 ( "" ) ; }
org . junit . Assert . assertThat ( meta . METHOD_12 ( ) , org . hamcrest . CoreMatchers . is ( STRING_0 ) )