Skip to content

Commit 6eebf98

Browse files
andre-tebartbjhaid
authored andcommitted
Fix socket error for OTP 28
1 parent dd1983c commit 6eebf98

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

lib/kafka_ex/socket.ex

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,8 +110,10 @@ defmodule KafkaEx.Socket do
110110
end
111111

112112
defp extract_port(%KafkaEx.Socket{ssl: true} = socket) do
113-
{:sslsocket, {:gen_tcp, port, _, _}, _} = socket.socket
114-
port
113+
case socket.socket do
114+
{:sslsocket, {:gen_tcp, port, _, _}, _} -> port # OTP pre 28
115+
{:sslsocket, port, _, _, :gen_tcp, _, _, _} -> port # OTP 28
116+
end
115117
end
116118

117119
defp extract_port(socket), do: socket.socket

0 commit comments

Comments
 (0)