METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 ; final java . lang . String IDENT_1 = STRING_1 ; com . IDENT_2 . config . IDENT_3 config = com . IDENT_2 . config . IDENT_4 . load ( ) ; final java . util . concurrent . atomic . IDENT_5 IDENT_6 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; org . apache . IDENT_7 . IDENT_8 . engine . IDENT_9 . IDENT_10 IDENT_9 = new org . apache . IDENT_7 . IDENT_8 . engine . IDENT_9 . METHOD_2 ( config , IDENT_0 , null , 1 ) { @ org . apache . IDENT_7 . IDENT_8 . engine . IDENT_11 . Override MOD_0 IDENT_12 . kafka . IDENT_13 METHOD_3 ( com . IDENT_2 . config . IDENT_3 config , java . util . Map conf , IDENT_14 . IDENT_12 . task . IDENT_15 context , IDENT_14 . IDENT_12 . IDENT_9 . IDENT_16 IDENT_17 , final java . lang . String IDENT_18 , java . lang . String IDENT_19 , org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . IDENT_21 IDENT_22 , java . util . Map < java . lang . String , org . apache . IDENT_7 . IDENT_8 . engine . IDENT_23 . IDENT_24 > IDENT_25 ) { return new IDENT_12 . kafka . METHOD_4 ( null , null ) ; } @ org . apache . IDENT_7 . IDENT_8 . engine . IDENT_11 . Override MOD_0 void METHOD_5 ( IDENT_12 . kafka . METHOD_4 IDENT_26 ) { org . apache . IDENT_7 . IDENT_8 . engine . IDENT_11 . IDENT_27 . LOG . info ( STRING_2 ) ; IDENT_6 . set ( true ) ; } } ; java . util . Map < java . lang . String , org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . IDENT_28 > IDENT_29 = METHOD_6 ( IDENT_1 , IDENT_30 ) ; org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . IDENT_31 IDENT_32 = new org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_7 ( IDENT_30 , STRING_3 ) ; java . util . Map < java . lang . String , java . util . List < org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_7 > > IDENT_22 = new java . util . HashMap < java . lang . String , java . util . List < org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_7 > > ( ) ; IDENT_22 . put ( IDENT_30 , java . util . Arrays . asList ( IDENT_32 ) ) ; org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . IDENT_21 IDENT_33 = new org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_8 ( IDENT_0 , IDENT_22 , null , IDENT_29 ) ; IDENT_9 . METHOD_9 ( IDENT_33 , null ) ; try { IDENT_9 . METHOD_9 ( new org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_8 ( IDENT_0 , new java . util . HashMap < java . lang . String , java . util . List < org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . METHOD_7 > > ( ) , new java . util . HashMap ( ) , new java . util . HashMap < java . lang . String , org . apache . IDENT_7 . IDENT_8 . IDENT_20 . model . IDENT_28 > ( ) ) , null ) ; } catch ( java . lang . Exception ex ) { org . apache . IDENT_7 . IDENT_8 . engine . IDENT_11 . IDENT_27 . LOG . error ( STRING_4 , ex ) ; throw ex ; } "<AssertPlaceHolder>" ; } get ( ) { return new org . apache . IDENT_7 . app . IDENT_34 . impl . METHOD_10 ( ) ; }
org . junit . Assert . assertTrue ( IDENT_6 . get ( ) )