METHOD_0 ( ) { task . start ( props ) ; com . google . IDENT_0 . v1 . IDENT_1 IDENT_2 = com . google . IDENT_0 . v1 . IDENT_1 . METHOD_1 ( ) . build ( ) ; when ( IDENT_3 . METHOD_2 ( any ( com . google . IDENT_0 . v1 . IDENT_4 . class ) ) . get ( ) ) . thenReturn ( IDENT_2 ) ; "<AssertPlaceHolder>" ; verify ( IDENT_3 , METHOD_3 ( ) ) . METHOD_4 ( any ( com . google . IDENT_0 . v1 . IDENT_5 . class ) ) ; } METHOD_5 ( ) { METHOD_4 ( ) ; com . google . IDENT_0 . kafka . source . IDENT_6 . log . debug ( STRING_0 ) ; com . google . IDENT_0 . v1 . IDENT_4 request = com . google . IDENT_0 . v1 . IDENT_4 . METHOD_1 ( ) . METHOD_6 ( IDENT_7 ) . METHOD_7 ( false ) . METHOD_8 ( IDENT_8 ) . build ( ) ; try { com . google . IDENT_0 . v1 . IDENT_1 response = IDENT_3 . METHOD_2 ( request ) . get ( ) ; java . util . List < org . apache . kafka . connect . source . IDENT_9 > IDENT_10 = new java . util . ArrayList ( ) ; com . google . IDENT_0 . kafka . source . IDENT_6 . log . trace ( ( ( STRING_1 + ( response . METHOD_9 ( ) . size ( ) ) ) + STRING_2 ) ) ; for ( com . google . IDENT_0 . v1 . IDENT_11 IDENT_12 : response . METHOD_9 ( ) ) { com . google . IDENT_0 . v1 . IDENT_13 message = IDENT_12 . getMessage ( ) ; java . lang . String IDENT_14 = IDENT_12 . METHOD_10 ( ) ; if ( ( ( IDENT_15 . contains ( IDENT_14 ) ) || ( IDENT_16 . contains ( IDENT_14 ) ) ) || ( IDENT_17 . contains ( IDENT_14 ) ) ) { continue ; } IDENT_15 . add ( IDENT_14 ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_18 = message . METHOD_11 ( ) ; java . lang . String key = IDENT_18 . get ( IDENT_19 ) ; java . lang . Long IDENT_20 = METHOD_12 ( IDENT_18 . get ( IDENT_21 ) ) ; if ( IDENT_20 == null ) { IDENT_20 = com . google . IDENT_22 . util . IDENT_23 . METHOD_13 ( message . METHOD_14 ( ) ) ; } com . google . IDENT_22 . IDENT_24 IDENT_25 = message . METHOD_15 ( ) ; byte [ ] IDENT_26 = IDENT_25 . toByteArray ( ) ; boolean IDENT_27 = ! ( IDENT_28 . METHOD_16 ( IDENT_18 . METHOD_17 ( ) ) ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_29 = java . util . Collections . METHOD_18 ( IDENT_7 , IDENT_14 ) ; org . apache . kafka . connect . source . IDENT_9 record = null ; if ( IDENT_27 ) { org . apache . kafka . connect . data . IDENT_30 IDENT_31 = org . apache . kafka . connect . data . IDENT_30 . METHOD_19 ( ) . field ( IDENT_32 . IDENT_33 , Schema . IDENT_34 ) ; for ( java . util . Map . Entry < java . lang . String , java . lang . String > IDENT_35 : IDENT_18 . entrySet ( ) ) { if ( ! ( IDENT_35 . getKey ( ) . equals ( IDENT_19 ) ) ) { IDENT_31 . field ( IDENT_35 . getKey ( ) , Schema . IDENT_36 ) ; } } org . apache . kafka . connect . data . Schema IDENT_37 = IDENT_31 . build ( ) ; org . apache . kafka . connect . data . IDENT_38 value = new org . apache . kafka . connect . data . METHOD_20 ( IDENT_37 ) . put ( IDENT_32 . IDENT_33 , IDENT_26 ) ; for ( org . apache . kafka . connect . data . Field field : IDENT_37 . fields ( ) ) { if ( ! ( field . name ( ) . equals ( IDENT_32 . IDENT_33 ) ) ) { value . put ( field . name ( ) , IDENT_18 . get ( field . name ( ) ) ) ; } } record = new org . apache . kafka . connect . source . METHOD_21 ( null , IDENT_29 , IDENT_39 , METHOD_22 ( key , value ) , org . apache . kafka . connect . data . Schema . IDENT_40 , key , IDENT_37 , value , IDENT_20 ) ; } else { record = new org . apache . kafka . connect . source . METHOD_21 ( null , IDENT_29 , IDENT_39 , METHOD_22 ( key , IDENT_26 ) , org . apache . kafka . connect . data . Schema . IDENT_40 , key , org . apache . kafka . connect . data . Schema . IDENT_34 , IDENT_26 , IDENT_20 ) ; } IDENT_10 . add ( record ) ; } return IDENT_10 ; } catch ( java . lang . Exception e ) { com . google . IDENT_0 . kafka . source . IDENT_6 . log . info ( ( STRING_3 + e ) ) ; return new java . util . ArrayList ( ) ; } }
org . junit . Assert . assertEquals ( 0 , task . METHOD_5 ( ) . size ( ) )