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