diff --git a/changelog.md b/changelog.md
index 84e1757..504a7a6 100644
--- a/changelog.md
+++ b/changelog.md
@@ -1,3 +1,6 @@
+* 1.10.3
+  - Fixed typespec for `wolff_client:get_leader_connections/3`.
+
 * 1.10.2 (merge 1.5.13)
   - Use long-lived metadata connection.
     This is to avoid having to excessively re-establish connection when there are many concurrent connectivity checks.
diff --git a/src/wolff.app.src b/src/wolff.app.src
index 8866472..498e7bb 100644
--- a/src/wolff.app.src
+++ b/src/wolff.app.src
@@ -1,6 +1,6 @@
 {application, wolff,
  [{description, "Kafka's publisher"},
-  {vsn, "1.10.2"},
+  {vsn, "1.10.3"},
   {registered, []},
   {applications,
    [kernel,
diff --git a/src/wolff.appup.src b/src/wolff.appup.src
index 5a5a3a5..83ff639 100644
--- a/src/wolff.appup.src
+++ b/src/wolff.appup.src
@@ -1,5 +1,5 @@
 %% -*- mode: erlang; -*-
-{"1.10.2",
+{"1.10.3",
   [
   ],
   [
diff --git a/src/wolff_client.erl b/src/wolff_client.erl
index 908caa6..4563649 100644
--- a/src/wolff_client.erl
+++ b/src/wolff_client.erl
@@ -99,7 +99,7 @@ get_id(Pid) ->
 get_leader_connections(Client, Topic) ->
    safe_call(Client, {get_leader_connections, Topic, all_partitions}).
 
--spec get_leader_connections(pid(), topic(), pos_integer()) ->
+-spec get_leader_connections(pid(), topic(), all_partitions | pos_integer()) ->
         {ok, [{partition(), pid() | ?conn_down(_)}]} | {error, any()}.
 get_leader_connections(Client, Topic, MaxPartitions) ->
    safe_call(Client, {get_leader_connections, Topic, MaxPartitions}).