diff --git a/apps/efka/src/iot/efka_iot_client.erl b/apps/efka/src/iot/efka_iot_client.erl
index 958e9ed..d6ed883 100644
--- a/apps/efka/src/iot/efka_iot_client.erl
+++ b/apps/efka/src/iot/efka_iot_client.erl
@@ -452,8 +452,8 @@ handle_container_command(Ref, Request, Socket) ->
     ok.
 
 -spec handle_stream_frame(term(), term(), #state{}) -> gen_statem:event_handler_result(atom(), #state{}).
-handle_stream_frame(StreamId, <<"open">>, State = #state{streams = Streams})
-    when is_integer(StreamId), StreamId > 0 ->
+handle_stream_frame(StreamId, {<<"open">>, Params}, State = #state{streams = Streams})
+    when is_integer(StreamId), StreamId > 0, is_map(Params) ->
     case valid_iot_stream_id(StreamId) andalso not maps:is_key(StreamId, Streams) of
         true ->
             {ok, {WorkerPid, MonitorRef}} = efka_iot_stream:start_stream(StreamId),
diff --git a/config/sys.config.src b/config/sys.config.src
index 372313c..abd8c5e 100644
--- a/config/sys.config.src
+++ b/config/sys.config.src
@@ -17,7 +17,7 @@
 
     {stream_target, [
         {host, "127.0.0.1"},
-        {port, 18091},
+        {port, 81},
         {connect_timeout, 3000},
         {idle_timeout, 120000}
     ]},