hjy30312

Results 1 issues of hjy30312

``` ThreadPoolExecutor executor = new ThreadPoolExecutor(10, 50, 60, TimeUnit.SECONDS, new SynchronousQueue(), Executors.defaultThreadFactory(), new ThreadPoolExecutor.CallerRunsPolicy() ); @KafkaListener(topics = "writeData") public void writeData(String message){ executor.execute(() -> { xxxxxx xxxxxxx }); } ```...