eddy147

eddy147

Kafka_ex :unsupported_version

On our staging server we have Kafka 2.8.1 installed. Running our app with kafka_ex 0.13 gives a :unsupported_version error: (our app is called dockr, not a typo )

 | 10:00:39.308 [error] GenServer #PID<0.1259.0> terminating
app_1  | ** (CaseClauseError) no case clause matching: :unsupported_version
app_1  |     (kafka_ex 0.13.0) lib/kafka_ex/gen_consumer.ex:929: KafkaEx.GenConsumer.load_offsets/1
app_1  |     (kafka_ex 0.13.0) lib/kafka_ex/gen_consumer.ex:660: KafkaEx.GenConsumer.handle_info/2
app_1  |     (stdlib 4.2) gen_server.erl:1123: :gen_server.try_dispatch/4
app_1  |     (stdlib 4.2) gen_server.erl:1200: :gen_server.handle_msg/6
app_1  |     (stdlib 4.2) proc_lib.erl:240: :proc_lib.init_p_do_apply/3
app_1  | Last message: :timeout
app_1  | State: %KafkaEx.GenConsumer.State{consumer_module: Dockr.Kafka.Consumer, consumer_state: nil, commit_interval: 1000, commit_threshold: 100, worker_name: #PID<0.1260.0>, group: "dockr-cg", topic: "dockr", partition: 1, member_id: "kafka_ex-8066c9fb-9d7b-40e9-8159-91e06eec48d0", generation_id: 17, current_offset: nil, committed_offset: nil, acked_offset: nil, last_commit: nil, auto_offset_reset: :earliest, fetch_options: [auto_commit: false, worker_name: #PID<0.1260.0>], api_versions: %{fetch: 0, offset_commit: 0, offset_fetch: 0}}

I have tried to reproduce the issue locally; I can not find a kafka docker container or an install that has 2.8.1;
I tried it wih with all kinds of versions of cp-confluent (6.2.x), also installed kafka 2.8.2 from apache, but it all works well locally.

Anyone recognizes this what could be the issue?

Many thx in advance.

Marked As Solved

eddy147

eddy147

For anyone who faces the same issue: the reason for this was that the Kafka that was installed was Confluent Kafka, which apparently uses a different protocol which caused the issue.

I would have liked that the error was a bit more verbose than :unsupported_version.

Where Next?

Popular in Questions Top

Darmani72
If I have a post route which an argument: post /my_post_route/:my_param1, MyController.my_post_handler How would get the post params ...
New
fireproofsocks
I’m working on defining a simple Ecto schema for a table (in PostGres), but I don’t see where I can define a column as NOT NULL. Conside...
New
ovidiubadita
Hey all, I discovered Elixir and I love it. I always wanted to learn a functional programming and I intended to go for Haskell, but afte...
New
nobody
How to bind a phoenix app to a specific ip address? could not find anything about that, nowhere, unfortunately, but for me this is quite...
New
LegitStack
I’m trying to make a websocket server in Phoenix or raw Elixir. I heard about gun, I think I could use cowboy, but since I’m not that sma...
New
itssasanka
Hi all, Trying to get some more clarity over utc_datetime and naive_datetime for Ecto: The documentation above suggests that while ...
New
fayddelight
I tried installing elixir 1.11.2 erlang 23.3.4 via asdf in my zsh shell. Enabled the versions locally and globally. When I list them ...
New
script
If I have a string “1000 cfu/ml” . I want to remove the characters and / and space . So the string is like this "1000" What is the ...
New
dotdotdotPaul
Okay, I’m having a heck of a time trying to figure out how to best handle the validation of belongs_to associations in Ecto. I’m sure I’...
New
marick
I had some trouble figuring out how to make many-to-many associations work. Once I got it working, I wrote a blog post. Because I’m a nov...
New

Other popular topics Top

danschultzer
None of the current solutions worked well for me, so I went ahead and built a user management system from scratch. This project took far...
548 29377 241
New
marius95
Hello everyone, I try to use an Javascript Event Handler in my root.html.leex file. Therefore I created a function in the app.js file: ...
New
sorentwo
Hello! tl;dr Announcing Oban, an Ecto based job processing library with a focus on reliability and historical observability. After spen...
985 42920 311
New
skosch
To my knowledge, put_in, Map.update etc. all have the one limitation of not automatically creating intermediate keys when needed (for exa...
New
JeremM34
Hello, how can I check the Phoenix version ? Thanks !
New
msaraiva
Surface is an experimental library built on top of Phoenix LiveView and its new LiveComponent API that aims to provide a more declarative...
564 43622 214
New
stefanchrobot
What’s the safe way to decode a JSON string into a struct? I want to avoid calling String.to_atom. Jason.decode can give me a map with st...
New
rms.mrcs
Hi, I need to transform a list of numbers into a map where the keys are the indexes and the values are the original values of the list. ...
New
shijith.k
I am trying to start a new phoenix project with elixir 1.9, but mix phx.new does not work. It says that ** (Mix) The task "phx.new" could...
New
AstonJ
Seen any cool LiveView demos, sample apps or examples? Please post them here! :003:
New

We're in Beta

About us Mission Statement