search

kafkaex / kafka_ex

Kafka client library for Elixir
MIT License
596 stars 162 forks source link

Fix socket close error #408

Closed dantswain closed 4 years ago

dantswain commented 4 years ago

I think I introduced this error in #406 -

** (EXIT) an exception was raised:
        ** (UndefinedFunctionError) function nil.socket/0 is undefined
            nil.socket()
            (kafka_ex) lib/kafka_ex/new/client.ex:703: anonymous fn/2 in KafkaEx.New.Client.close_broker_by_socket/2
            (kafka_ex) lib/kafka_ex/new/cluster_metadata.ex:228: anonymous fn/2 in KafkaEx.New.ClusterMetadata.update_brokers/2
            (elixir) lib/map.ex:216: Map.new_transform/3
            (kafka_ex) lib/kafka_ex/new/cluster_metadata.ex:227: KafkaEx.New.ClusterMetadata.update_brokers/2
            (kafka_ex) lib/kafka_ex/new/client/state.ex:76: KafkaEx.New.Client.State.update_brokers/2
            (kafka_ex) lib/kafka_ex/new/client.ex:184: KafkaEx.New.Client.handle_info/2
            (stdlib) gen_server.erl:637: :gen_server.try_dispatch/4