METHOD_0 ( ) { state . METHOD_1 ( METHOD_2 ( IDENT_0 ) , IDENT_1 ) ; "<AssertPlaceHolder>" ; state . position ( IDENT_2 , 0 ) ; } METHOD_3 ( java . util . Collection ) { if ( ! ( this . METHOD_4 ( ) ) ) throw new java . lang . IllegalArgumentException ( STRING_0 ) ; java . util . function . IDENT_3 < org . apache . kafka . common . IDENT_4 > IDENT_5 = ( IDENT_6 ) -> { if ( ( this . IDENT_7 ) != null ) { boolean match = this . IDENT_7 . matcher ( IDENT_6 . METHOD_5 ( ) ) . matches ( ) ; if ( ! match ) { log . info ( STRING_1 , IDENT_6 , this . IDENT_7 ) ; } return match ; } else { boolean match = this . IDENT_8 . contains ( IDENT_6 . METHOD_5 ( ) ) ; if ( ! match ) { log . info ( STRING_2 , IDENT_6 , this . IDENT_8 ) ; } return match ; } } ; boolean IDENT_9 = IDENT_10 . stream ( ) . METHOD_6 ( IDENT_5 ) ; if ( IDENT_9 ) { java . util . Map < org . apache . kafka . common . IDENT_4 , org . apache . kafka . IDENT_11 . consumer . IDENT_12 . IDENT_13 . IDENT_14 > IDENT_15 = org . apache . kafka . IDENT_11 . consumer . IDENT_12 . IDENT_13 . METHOD_7 ( IDENT_10 ) ; ( IDENT_16 ) ++ ; this . IDENT_17 . set ( IDENT_15 ) ; } return IDENT_9 ; }
org . junit . Assert . assertTrue ( state . METHOD_3 ( METHOD_2 ( IDENT_2 ) ) )