Set CDC client nThreads of event loop group (#28682)

apache · Oct 8, 2023 · 38405b2 · 38405b2
1 parent 0e824cf
commit 38405b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...dc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java b/...dc/client/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/client/CDCClient.java
@@ -81,7 +81,7 @@ private void validateParameter(final CDCClientConfiguration parameter) {
     @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)