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 , "" ) ; "<AssertPlaceHolder>" ; } METHOD_2 ( java . util . List , java . lang . String ) { if ( com . google . common . base . IDENT_1 . METHOD_3 ( cluster ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_2 ) . entity ( java . lang . String . format ( STRING_1 , com . IDENT_3 . druid . IDENT_4 . IDENT_5 . IDENT_6 ) ) . build ( ) ; } if ( ( events == null ) || ( events . isEmpty ( ) ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_2 ) . entity ( STRING_2 ) . build ( ) ; } final org . apache . kafka . IDENT_7 . IDENT_8 . IDENT_9 IDENT_10 = new org . apache . kafka . IDENT_7 . IDENT_8 . METHOD_4 ( ) { @ com . IDENT_3 . druid . IDENT_4 . Override public void METHOD_5 ( org . apache . kafka . IDENT_7 . IDENT_8 . IDENT_11 metadata , java . lang . Exception exception ) { if ( exception == null ) { IDENT_12 . METHOD_6 ( cluster ) ; } else { IDENT_12 . METHOD_7 ( cluster ) ; com . IDENT_3 . druid . IDENT_4 . IDENT_5 . 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_13 = event . get ( com . IDENT_3 . druid . IDENT_4 . IDENT_5 . IDENT_14 ) ; if ( ( IDENT_13 == null ) || ( ! ( com . IDENT_3 . druid . IDENT_4 . IDENT_5 . IDENT_15 . contains ( IDENT_13 ) ) ) ) { return javax . ws . rs . core . Response . status ( Response . Status . IDENT_2 ) . entity ( STRING_4 ) . build ( ) ; } event . put ( com . IDENT_3 . druid . IDENT_4 . IDENT_5 . IDENT_6 , cluster ) ; final java . lang . String IDENT_16 = ( ( IDENT_17 ) + STRING_5 ) + IDENT_13 ; final java . lang . String IDENT_18 = IDENT_19 . METHOD_8 ( event ) ; IDENT_12 . METHOD_9 ( cluster , IDENT_18 . getBytes ( ) . length ) ; final org . apache . kafka . IDENT_7 . IDENT_8 . IDENT_20 < java . lang . String , java . lang . String > record = new org . apache . kafka . IDENT_7 . IDENT_8 . METHOD_10 ( IDENT_16 , null , IDENT_18 ) ; try { IDENT_8 . METHOD_11 ( record , IDENT_10 ) ; } catch ( java . lang . Exception exception ) { IDENT_12 . METHOD_7 ( cluster ) ; com . IDENT_3 . druid . IDENT_4 . IDENT_5 . 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_2 . getStatusCode ( ) , IDENT_0 . getStatus ( ) )