[INLONG-11662][SDK] Enable TCP keep alive for Golang SDK (#11666)

apache · Jan 15, 2025 · a110f9f · a110f9f
1 parent 9247e42
commit a110f9f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go b/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go
@@ -22,6 +22,7 @@ import (
 	"errors"
 	"math"
 	"sync"
+	"time"
 
 	"github.com/apache/inlong/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool"
 	"github.com/apache/inlong/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/discoverer"
@@ -135,7 +136,8 @@ func (c *client) initNetClient() error {
 		gnet.WithWriteBufferCap(c.options.WriteBufferSize),
 		gnet.WithReadBufferCap(c.options.ReadBufferSize),
 		gnet.WithSocketSendBuffer(c.options.SocketSendBufferSize),
-		gnet.WithSocketRecvBuffer(c.options.SocketRecvBufferSize))
+		gnet.WithSocketRecvBuffer(c.options.SocketRecvBufferSize),
+		gnet.WithTCPKeepAlive(5*time.Minute))
 	if err != nil {
 		return err
 	}