[Q/A][Java SDK (Component)] The issue with Dubbo threads

[MyFatBoy]

Pre-check

• I am sure that all the content I provide is in English.

Apache Dubbo Component

Java SDK (apache/dubbo)

Details

I have a project in which a service listens to a Kafka topic to retrieve data, and then uses @DubboReference(check = false) to call another service to process (consume) the data obtained from Kafka. However, because there is too much data coming from Kafka, the downstream service cannot keep up with the consumption speed, leading to all threads being exhausted and eventually causing an error: java.util.concurrent.RejectedExecutionException: null. How can I solve this issue?

Code of Conduct

• I agree to follow this project's Code of Conduct

[AlbumenJ]

You can try upgrade to the latest version

[MyFatBoy]

Sorry, I forgot to mention earlier. My Dubbo version is 3.3.3, StringBoot version is 3.4.3, and JDK version is 21.