Error before/on Elsa.Producer.ready?

[tpitale]

Elixir.Elsa.DynamicProcessManager: initializer raised exception, retrying: %KeyError{key: :topic_metadata, message: nil, term: %{brokers: [%{host: "localhost", node_id: 1001, port: 9092, rack: ""}], cluster_id: "AVee9UIwRfK0ZV_sVCUcsg", controller_id: 1001, topics: [%{error_code: :no_error, is_internal: false, name: "compact_entitlements", partitions: [%{error_code: :no_error, isr_nodes: [1001], leader_id: 1001, partition_index: 0, replica_nodes: [1001]}, %{error_code: :no_error, isr_nodes: [1001], leader_id: 1001, partition_index: 1, replica_nodes: [1001]}, %{error_code: :no_error, isr_nodes: [1001], leader_id: 1001, partition_index: 2, replica_nodes: [1001]}]}]}}

Trying to call Elsa.Producer.ready?(connection) after having started a supervisor for the topic so I can produce some data:

    {:ok, _} =
      Elsa.Supervisor.start_link(
        connection: connection,
        endpoints: brokers(),
        producer: [
          topic: to_string(topic)
        ]
      )

[tpitale]

The issue is the change in brod 3.16 to the map structure returned for topic metadata. It is now just :topics and :partitions and not :topic_metadata and :partition_metadata.