gheidorn

gheidorn

Kafka_Ex Connection Issue

I’m trying to get started with kafka_ex and can’t seem to even get it configured correctly. I am using the out of the box config with just the broker changed to localhost:2181 (testing locally). When I run my IEX session, I get this error:

22:49:31.422 [debug] Succesfully connected to broker "localhost":2181

22:49:31.442 [error] Receiving data from broker "localhost":2181 failed with :closed

22:49:31.442 [error] Unable to fetch metadata from any brokers.  Timeout is 3000.

22:49:31.454 [info]  Application kafka_ex exited: KafkaEx.start(:normal, []) returned an error: an exception was raised:
    ** (RuntimeError) Unable to fetch metadata from any brokers.  Timeout is 3000.
        (kafka_ex) lib/kafka_ex/server.ex:393: KafkaEx.Server0P9P0.retrieve_metadata/6
        (kafka_ex) lib/kafka_ex/server_0_p_9_p_0.ex:62: KafkaEx.Server0P9P0.kafka_server_init/1
        (stdlib) gen_server.erl:365: :gen_server.init_it/2
        (stdlib) gen_server.erl:333: :gen_server.init_it/6
        (stdlib) proc_lib.erl:247: :proc_lib.init_p_do_apply/3
** (Mix) Could not start application kafka_ex: KafkaEx.start(:normal, []) returned an error: an exception was raised:
    ** (RuntimeError) Unable to fetch metadata from any brokers.  Timeout is 3000.
        (kafka_ex) lib/kafka_ex/server.ex:393: KafkaEx.Server0P9P0.retrieve_metadata/6
        (kafka_ex) lib/kafka_ex/server_0_p_9_p_0.ex:62: KafkaEx.Server0P9P0.kafka_server_init/1
        (stdlib) gen_server.erl:365: :gen_server.init_it/2
        (stdlib) gen_server.erl:333: :gen_server.init_it/6
        (stdlib) proc_lib.erl:247: :proc_lib.init_p_do_apply/3

Any ideas on what I might be doing wrong? Thanks in advance!

Marked As Solved

IanVaughan

IanVaughan

Hi, silly question, but are you sure your broker is on 2181? As normally it binds to 9092.
The error is what I get when I’ve not started the kafka broker.

Also Liked

gheidorn

gheidorn

Not a silly question at all. I totally made this mistake! Thank you for your reply.

[debug] Succesfully connected to broker "localhost":9092
[debug] Establishing connection to broker 0: "172.24.162.59" on port 9092
[debug] Succesfully connected to broker "172.24.162.59":9092

Where Next?

Trending in Questions Top

lanycrost
Hi everyone! I need implement if…else if…else condition from my elixir code, and anymore of this control flow structures not work proper...
New
senggen
Erlang/OTP 25 [erts-13.2.2] [source] [64-bit] [smp:8:8] [ds:8:8:10] [async-threads:1] 15:22:35.803 [error] gen_event {lager_file_backend...
New
hariharasudhan94
Lets say I have map like this fetching from my database %{"_id" => #BSON.ObjectId<58eb1a7a9ad169198c3dXXXX>, "email" => ...
New
tj0
I’ve been following the steps here for the upgrade from 1.6 to 1.7 and it has gone relatively smoothly all the way till the phoenix_view ...
New
cgraham
Hi! What is currently the best library/method for parsing text and tabular data out of PDF files in Elixir or Erlang?
New
stefanchrobot
Hi, I need a way to handle data migrations in my application. I found an article by @wojtekmach about manual migrations: Automatic and ma...
New
stjefim
Hello! Suppose you are building workflow (order / task / payment) processing system with the following requirements: Each workflow con...
New

Other Trending Topics Top

GenericJam
Edit: 2026 May 15 - This post is archived. Mob is alive!! Main docs: mob v0.7.11 — Documentation A bit of explanation for the slightly c...
New
JesseHerrick
Hey, I’m Jesse and I’m the main contributor behind Dexter, a full-featured, lightning-fast Elixir LSP optimized for large codebases. It s...
New
kip
Localize is the next generation localisation library for Elixir. Think of it as ex_cldr version 3.0. The first version will be released ...
New
webofbits
Squid Mesh is an open source workflow automation runtime for Elixir applications. It is aimed at Phoenix and OTP apps that want to defin...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
kip
In 2021 I started a new library called Tempo with the objective of modelling time as a set of intervals - not as instants. In 2022 I gave...
New

We're in Beta

About us Mission Statement