METHOD_0 ( ) { java . util . List < java . util . Map < java . lang . String , java . lang . Object > > in = METHOD_1 ( STRING_0 ) ; javax . ws . rs . core . Response IDENT_0 = resource . METHOD_2 ( in , com . IDENT_1 . druid . IDENT_2 . IDENT_3 . IDENT_4 ) ; "<AssertPlaceHolder>" ; } METHOD_2 ( java . util . List , java . lang . String ) { if ( com . google . common . base . IDENT_5 . METHOD_3 ( cluster ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_6 ) . entity ( java . lang . String . format ( STRING_1 , com . IDENT_1 . druid . IDENT_2 . IDENT_7 . IDENT_8 ) ) . build ( ) ; } if ( ( events == null ) || ( events . isEmpty ( ) ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_6 ) . entity ( STRING_2 ) . build ( ) ; } final org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_11 IDENT_12 = new org . apache . kafka . IDENT_9 . IDENT_10 . METHOD_4 ( ) { @ com . IDENT_1 . druid . IDENT_2 . Override public void METHOD_5 ( org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_13 metadata , java . lang . Exception exception ) { if ( exception == null ) { IDENT_14 . METHOD_6 ( cluster ) ; } else { IDENT_14 . METHOD_7 ( cluster ) ; com . IDENT_1 . druid . IDENT_2 . IDENT_7 . log . error ( exception , STRING_3 , cluster , exception . getMessage ( ) ) ; } } } ; for ( final java . util . Map < java . lang . String , java . lang . Object > event : events ) { java . lang . Object IDENT_15 = event . get ( com . IDENT_1 . druid . IDENT_2 . IDENT_7 . IDENT_16 ) ; if ( ( IDENT_15 == null ) || ( ! ( com . IDENT_1 . druid . IDENT_2 . IDENT_7 . IDENT_17 . contains ( IDENT_15 ) ) ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_6 ) . entity ( STRING_4 ) . build ( ) ; } event . put ( com . IDENT_1 . druid . IDENT_2 . IDENT_7 . IDENT_8 , cluster ) ; final java . lang . String IDENT_18 = ( ( IDENT_19 ) + STRING_5 ) + IDENT_15 ; final java . lang . String IDENT_20 = IDENT_21 . METHOD_8 ( event ) ; IDENT_14 . METHOD_9 ( cluster , IDENT_20 . getBytes ( ) . length ) ; final org . apache . kafka . IDENT_9 . IDENT_10 . IDENT_22 < java . lang . String , java . lang . String > record = new org . apache . kafka . IDENT_9 . IDENT_10 . METHOD_10 ( IDENT_18 , null , IDENT_20 ) ; try { IDENT_10 . METHOD_11 ( record , IDENT_12 ) ; } catch ( java . lang . Exception exception ) { IDENT_14 . METHOD_7 ( cluster ) ; com . IDENT_1 . druid . IDENT_2 . IDENT_7 . log . error ( exception , STRING_6 ) ; return javax . ws . rs . core . Response . METHOD_12 ( ) . entity ( STRING_7 ) . build ( ) ; } } return javax . ws . rs . core . Response . METHOD_13 ( ) . build ( ) ; }
org . junit . Assert . assertEquals ( Response . Status . IDENT_6 . getStatusCode ( ) , IDENT_0 . getStatus ( ) )