[shardingsphere] branch master updated: Set CDC client nThreads of event loop group (#28682)

[zhonghongsheng]

This is an automated email from the ASF dual-hosted git repository.

zhonghongsheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 38405b2f3bb Set CDC client nThreads of event loop group (#28682)
38405b2f3bb is described below

commit 38405b2f3bbf2baec069d9257d97afc62baaf3b2
Author: Xinze Guo <101622833+aze...@users.noreply.github.com>
AuthorDate: Sun Oct 8 20:18:09 2023 +0800

    Set CDC client nThreads of event loop group (#28682)
---
 .../org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
index abe9ede4905..ada8bf52152 100644
--- 
a/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
+++ 
b/kernel/data-pipeline/scenario/cdc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
@@ -81,7 +81,7 @@ public final class CDCClient implements AutoCloseable {
     @SneakyThrows(InterruptedException.class)
     public void connect() {
         Bootstrap bootstrap = new Bootstrap();
-        group = new NioEventLoopGroup();
+        group = new NioEventLoopGroup(1);
         bootstrap.channel(NioSocketChannel.class)
                 .group(group)
                 .option(ChannelOption.ALLOCATOR, 
PooledByteBufAllocator.DEFAULT)