Unable to connect to Azure EventHub using Kafka protocol about reactive-interaction-gateway

[patrickmedina]

Tried setting query_api_versions to false in lib/rig_kafka/client.ex:152 but encountered an SSL handshake issue during connection.

diff --git a/lib/rig_kafka/client.ex b/lib/rig_kafka/client.ex
index be3af82e..1685fedf 100644
--- a/lib/rig_kafka/client.ex
+++ b/lib/rig_kafka/client.ex
@@ -152,6 +152,7 @@ defmodule RigKafka.Client do
       [
         endpoints: brokers,
         auto_start_producers: true,
+       query_api_versions: false,
         default_producer_config: []
       ]
       |> add_ssl_conf(ssl)

Here's the logs from RIG

rig-dev    | ** (stop) exited in: :gen_server.call(:"brod_client_63510f32-dfd4-472e-8f7d-0f673acdf5fe", {:get_group_coordinator, "rig-proxy-response"}, :infinity)
rig-dev    |     ** (EXIT) [{{"realtime-update.servicebus.windows.net", 9093}, {{{:kpro_req, #Reference<0.2030329627.507248641.110356>, :sasl_handshake, 0, false, [[<<0, 5>>, "PLAIN"]]}, :closed}, [{:kpro_lib, :send_and_recv_raw, 4, [file: 'src/kpro_lib.erl', line: 70]}, {:kpro_lib, :send_and_recv, 5, [file: 'src/kpro_lib.erl', line: 81]}, {:kpro_sasl, :handshake, 6, [file: 'src/kpro_sasl.erl', line: 117]}, {:kpro_sasl, :auth, 7, [file: 'src/kpro_sasl.erl', line: 47]}, {:kpro_connection, :init_connection, 2, [file: 'src/kpro_connection.erl', line: 240]}, {:kpro_connection, :init, 4, [file: 'src/kpro_connection.erl', line: 170]}, {:proc_lib, :init_p_do_apply, 3, [file: 'proc_lib.erl', line: 226]}]}}]
rig-dev    |     (stdlib 3.14) gen_server.erl:246: :gen_server.call/3
rig-dev    |     (brod 3.15.1) /opt/sites/rig/deps/brod/src/brod_client.erl:839: :brod_client.safe_gen_call/3
rig-dev    |     (brod 3.15.1) /opt/sites/rig/deps/brod/src/brod_group_coordinator.erl:446: anonymous fn/2 in :brod_group_coordinator.discover_coordinator/1
rig-dev    |     (brod 3.15.1) /opt/sites/rig/deps/brod/src/brod_group_coordinator.erl:446: :brod_group_coordinator.discover_coordinator/1
rig-dev    |     (brod 3.15.1) /opt/sites/rig/deps/brod/src/brod_group_coordinator.erl:540: :brod_group_coordinator.do_stabilize/3
rig-dev    |     (brod 3.15.1) /opt/sites/rig/deps/brod/src/brod_group_coordinator.erl:349: :brod_group_coordinator.handle_info/2
rig-dev    |     (stdlib 3.14) gen_server.erl:689: :gen_server.try_dispatch/4
rig-dev    |     (stdlib 3.14) gen_server.erl:765: :gen_server.handle_msg/6
rig-dev    | Last message: {:lo_cmd_stabilize, 0, :undefined}
rig-dev    | State: {:state, :"brod_client_63510f32-dfd4-472e-8f7d-0f673acdf5fe", "rig-proxy-response", "", :undefined, 0, ["rig-proxy-response"], :undefined, :undefined, [], false, #PID<0.4004.0>, :brod_group_subscriber, [], :undefined, :roundrobin_v2, 30, 5, 5, 1, :undefined, :commit_to_kafka_v2, 5, :roundrobin_v2}
rig-dev    | 02:56:34.090 module=RigKafka.Client [warn] SASL is enabled, but SSL is not - credentials are transmitted as cleartext.
rig-dev    | 02:56:34.091 module=RigKafka.Client [warn] SASL is enabled, but SSL is not - credentials are transmitted as cleartext.
rig-dev    | 02:56:34.602 module=RigKafka.Client [warn] SASL is enabled, but SSL is not - credentials are transmitted as cleartext.
rig-dev    | 02:56:35.676 [warn] :brod_client [#PID<0.4019.0>] :"brod_client_63510f32-dfd4-472e-8f7d-0f673acdf5fe" is terminating
rig-dev    | reason: [
rig-dev    |   {{"realtime-update.servicebus.windows.net", 9093},
rig-dev    |    {{{:kpro_req, #Reference<0.2030329627.506986500.232614>, :sasl_handshake, 0,
rig-dev    |       false, [[<<0, 5>>, "PLAIN"]]}, :closed},
rig-dev    |     [
rig-dev    |       {:kpro_lib, :send_and_recv_raw, 4, [file: 'src/kpro_lib.erl', line: 70]},
rig-dev    |       {:kpro_lib, :send_and_recv, 5, [file: 'src/kpro_lib.erl', line: 81]},
rig-dev    |       {:kpro_sasl, :handshake, 6, [file: 'src/kpro_sasl.erl', line: 117]},
rig-dev    |       {:kpro_sasl, :auth, 7, [file: 'src/kpro_sasl.erl', line: 47]},
rig-dev    |       {:kpro_connection, :init_connection, 2,
rig-dev    |        [file: 'src/kpro_connection.erl', line: 240]},
rig-dev    |       {:kpro_connection, :init, 4, [file: 'src/kpro_connection.erl', line: 170]},
rig-dev    |       {:proc_lib, :init_p_do_apply, 3, [file: 'proc_lib.erl', line: 226]}
rig-dev    |     ]}}
rig-dev    | ]

[patrickmedina]

@kevinbader / @mmacai,

Tested #379 and confirmed it's working. I can now connect to Azure EventHub directly from RIG.