turn off Ack and Nagle? about confluent-kafka-go HOT 2 OPEN

	opt := &redis.Options{
		Addr: "localhost:6379",
		Dialer: func(ctx context.Context, network, addr string) (net.Conn, error) {
			conn, err := net.DialTimeout(network, addr, 5*time.Second)
			if err != nil {
				return nil, err
			}
			tcpConn, ok := conn.(*net.TCPConn)
			if !ok {
				return nil, err // Optionally, replace with a more specific error
			}
			if err := tcpConn.SetNoDelay(true); err != nil {
				return nil, err
			}
			return tcpConn, nil
		},
	}

// CustomDialer connects to RabbitMQ using a custom net.Dialer to disable Nagle's algorithm.
func CustomDialer(pool *RabbitMQConnectionPool) (*amqp.Connection, error) {
	//// custom dialer

	dialer := &net.Dialer{
		Timeout:   30 * time.Second,
		KeepAlive: 30 * time.Second,
	}

	conn, err := amqp.DialConfig(pool.connString, amqp.Config{
		Dial: func(network, addr string) (net.Conn, error) {
			c, err := dialer.Dial(network, addr)
			if err != nil {
				return nil, err
			}

			// Assuming c is a *net.TCPConn, disable Nagle's algorithm.
			if tcpConn, ok := c.(*net.TCPConn); ok {
				if err := tcpConn.SetNoDelay(true); err != nil {
					vbl.Stdout.WarnF("Failed to disable Nagle's algorithm: %v", err)
					// Handle error or proceed, depending on your error handling strategy.
				}
			}

			return c, nil
		},
	})
	return conn, err
}