diff --git a/src/event_retrier.ts b/src/event_retrier.ts
index d5cd86c..b7341e5 100644
--- a/src/event_retrier.ts
+++ b/src/event_retrier.ts
@@ -1,5 +1,10 @@
 import {DroppedError, RetryShutdownError} from "./error";
-import {awaitAtMost, pDefer, DeferredPromise} from "./util";
+import {
+  awaitAtMost,
+  pDefer,
+  DeferredPromise,
+  Max32BitSignedInteger,
+} from "./util";
 
 /**
  * Event retry settings
@@ -54,7 +59,7 @@ export class EventRetrier {
       backoff: 2,
       delay: 100,
       minDelay: -Infinity,
-      maxDelay: +Infinity,
+      maxDelay: Max32BitSignedInteger,
       onError: () => {},
       ...(opts || {}),
     };
diff --git a/src/socket.ts b/src/socket.ts
index 64c1de9..914f360 100644
--- a/src/socket.ts
+++ b/src/socket.ts
@@ -10,6 +10,7 @@ import {
 } from "./error";
 import * as protocol from "./protocol";
 import {PassThrough, Duplex} from "stream";
+import {Max32BitSignedInteger} from "./util";
 
 /**
  * Reconnection settings for the socket
@@ -320,7 +321,7 @@ export class FluentSocket extends EventEmitter {
       backoff: 2,
       delay: 500, // default is 500ms
       minDelay: -Infinity,
-      maxDelay: +Infinity,
+      maxDelay: Max32BitSignedInteger,
       ...(options.reconnect || {}),
     };
   }
diff --git a/src/util.ts b/src/util.ts
index 47d0e56..951ca84 100644
--- a/src/util.ts
+++ b/src/util.ts
@@ -43,3 +43,5 @@ export const pDefer = <T>(): DeferredPromise<T> => {
   });
   return deferred as DeferredPromise<T>;
 };
+
+export const Max32BitSignedInteger = 2 ** 31 - 1;