kafka_ex
kafka_ex copied to clipboard
kafkaex
Kafka client library for Elixir
When starting a supervisor tree from this example [KafkaEx.ConsumerGroup](https://github.com/kafkaex/kafka_ex/blob/0d222574a1178fcebca0824c193b86530d4ee8fb/lib/kafka_ex/consumer_group.ex#L54), I get the deprecation warning: ``` warning: Supervisor.Spec.supervisor/2 is deprecated. Use the new child specifications outlined in the Supervisor module instead...
I am encountering the below exception whenever Kafka restarts "Consumer group #{group_name} encountered nonexistent topic #{topic}" Any suggestions on how to handle when Kafka restarts? Below is the environment: Windows...
When using Kayrock with kafka_ex, we ran into an error around using SSL. ``` 16:53:56.681 [error] Could not connect to broker [redacted] because of error {:error, :ssl_not_started} ``` We tried...
Hi, I have started using `kafka_ex` for one of my IoT projects. I have a requirement for standalone consumer which is not placed inside any consumer group. There is support...
Is there currently a way to integrate SASL support? Thanks, James
Hi, I'm looking for a way to gracefully shutdown a consumer group. Let's say there is a setting that can be flipped to turn off consumption and that setting can...
I'm occasionally getting the following error on my test servers when starting consumer group manager: ```Elixir {:error, { %RuntimeError{ message: "Parse error during %Kayrock.ApiVersions.V0.Request{client_id: \"kafka_ex\", correlation_id: 0} response deserializer. Couldn't...
https://github.com/kafkaex/kafka_ex/blob/a1bd36052f4b212fda62795279775ebbc498c407/lib/kafka_ex/new/client.ex#L40 Requested ``` # additional function argument that can contain [name: my_desired_name] def start_link(args, name, opts) do GenServer.start_link(__MODULE__, [args, name], opts) end OR # where args contains the desired worker...
Travis-CI seems to be getting noticeably slower for OSS builds: https://www.traviscistatus.com/#month I've definitely noticed significant queue times for builds, which is a pretty major slowdown for iterating on PRs. Furthermore,...
This will be a fairly large undertaking. https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-TheAPIs Each message type has one or more versions, and the versions were implemented in a particular version of the broker. The correlation...