METHOD_0 ( ) { final org . apache . kafka . streams . state . IDENT_0 . IDENT_1 IDENT_2 = new org . apache . kafka . streams . state . IDENT_0 . METHOD_1 ( IDENT_3 , 10 , new org . apache . kafka . streams . processor . IDENT_0 . METHOD_2 ( new org . apache . kafka . common . metrics . METHOD_3 ( ) ) ) ; IDENT_2 . put ( IDENT_4 , org . apache . kafka . common . utils . IDENT_5 . METHOD_4 ( new byte [ ] { 1 } ) , METHOD_5 ( new byte [ ] { 1 } ) ) ; "<AssertPlaceHolder>" ; } get ( java . util . Collection , org . apache . kafka . connect . util . IDENT_6 ) { return executor . METHOD_6 ( new java . util . concurrent . IDENT_7 < java . util . Map < java . nio . ByteBuffer , java . nio . ByteBuffer > > ( ) { @ org . apache . kafka . connect . storage . Override public java . util . Map < java . nio . ByteBuffer , java . nio . ByteBuffer > call ( ) throws org . apache . kafka . connect . storage . Exception { java . util . Map < java . nio . ByteBuffer , java . nio . ByteBuffer > result = new java . util . HashMap ( ) ; for ( java . nio . ByteBuffer key : keys ) { result . put ( key , data . get ( key ) ) ; } if ( IDENT_8 != null ) IDENT_8 . METHOD_7 ( null , result ) ; return result ; } } ) ; }
org . junit . Assert . assertNull ( IDENT_2 . get ( IDENT_4 , null ) )