METHOD_0 ( ) { final java . util . List < org . apache . kafka . IDENT_0 . consumer . IDENT_1 < byte [ ] , byte [ ] > > records = java . util . Collections . singletonList ( new org . apache . kafka . IDENT_0 . consumer . METHOD_1 ( STRING_0 , 1 , 1 , ( - 1L ) , org . apache . kafka . common . record . IDENT_2 . IDENT_3 , 0L , 0 , 0 , IDENT_4 , IDENT_5 ) ) ; final org . apache . kafka . streams . processor . IDENT_6 . IDENT_7 queue = new org . apache . kafka . streams . processor . IDENT_6 . METHOD_2 ( new org . apache . kafka . common . METHOD_3 ( IDENT_8 [ 0 ] , 1 ) , new org . apache . kafka . test . METHOD_4 ( IDENT_8 , IDENT_9 , IDENT_9 ) , new org . apache . kafka . streams . processor . METHOD_5 ( ) , new org . apache . kafka . streams . errors . METHOD_6 ( ) , new org . apache . kafka . test . METHOD_7 ( ) , new org . apache . kafka . common . utils . METHOD_8 ( ) ) ; queue . METHOD_9 ( records ) ; "<AssertPlaceHolder>" ; } size ( ) { return ( headers ) == null ? 0 : headers . size ( ) ; }
org . junit . Assert . assertEquals ( 0 , queue . size ( ) )