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