METHOD_0 ( ) { for ( java . lang . String IDENT_0 : com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_5 ) { final java . lang . String IDENT_6 = STRING_0 + IDENT_0 ; METHOD_1 ( IDENT_6 ) ; final com . IDENT_1 . IDENT_2 . IDENT_3 . consumer . IDENT_7 consumer = METHOD_2 ( IDENT_6 , 0 ) ; error = null ; java . lang . Thread t = new java . lang . Thread ( new java . lang . METHOD_3 ( ) { @ com . IDENT_1 . IDENT_2 . IDENT_3 . Override public void run ( ) { try { byte [ ] bytes = new byte [ INT_0 * INT_0 ] ; java . lang . String line ; java . lang . String message ; int IDENT_8 ; for ( int i = 0 ; i < ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_9 . size ( ) ) ; i ++ ) { IDENT_8 = - 1 ; while ( IDENT_8 == ( - 1 ) ) { IDENT_8 = consumer . getMessage ( bytes , 0 , bytes . length ) ; } line = new java . lang . String ( bytes , 0 , IDENT_8 ) ; message = line . split ( " " , 4 ) [ 3 ] . trim ( ) ; "<AssertPlaceHolder>" ; } } catch ( java . lang . Throwable t ) { METHOD_4 ( t ) ; } } } ) ; t . start ( ) ; java . lang . Thread . sleep ( 100 ) ; kafka . IDENT_10 . IDENT_11 . IDENT_12 < java . lang . String , java . lang . String > IDENT_11 = METHOD_5 ( IDENT_0 ) ; for ( java . lang . String log : com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_9 ) { IDENT_11 . METHOD_6 ( new kafka . IDENT_11 . IDENT_13 < java . lang . String , java . lang . String > ( IDENT_6 , STRING_1 , ( ( ( java . lang . System . currentTimeMillis ( ) ) + STRING_2 ) + log ) ) ) ; } t . join ( ) ; if ( ( error ) != null ) { throw error ; } } } getMessage ( byte [ ] , int , int ) { IDENT_14 . METHOD_7 ( ) ; IDENT_15 . METHOD_7 ( ) ; try { if ( ( ( IDENT_16 ) == null ) || ( ( IDENT_16 . METHOD_8 ( ) ) == false ) ) { METHOD_9 ( ) ; if ( ( ( IDENT_16 ) == null ) || ( ( IDENT_16 . METHOD_8 ( ) ) == false ) ) { IDENT_17 . METHOD_7 ( ) ; IDENT_18 . METHOD_7 ( ) ; return - 1 ; } } IDENT_19 = IDENT_16 . getMessage ( buffer , pos , IDENT_20 ) ; if ( ( IDENT_19 ) == ( - 1 ) ) { IDENT_17 . METHOD_7 ( ) ; IDENT_18 . METHOD_7 ( ) ; return - 1 ; } IDENT_21 = IDENT_16 . METHOD_10 ( ) ; offset = IDENT_16 . METHOD_11 ( ) ; IDENT_22 . METHOD_7 ( ) ; IDENT_23 . METHOD_7 ( ) ; IDENT_24 . METHOD_7 ( IDENT_19 ) ; IDENT_25 . METHOD_7 ( IDENT_19 ) ; return IDENT_19 ; } catch ( java . net . IDENT_26 e ) { com . IDENT_1 . IDENT_2 . IDENT_3 . consumer . IDENT_7 . LOG . error ( STRING_3 , IDENT_6 , IDENT_27 , IDENT_28 . METHOD_12 ( ) , e ) ; METHOD_13 ( ) ; return - 1 ; } }
org . junit . Assert . assertEquals ( com . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 . IDENT_9 . get ( i ) , message )