elsa

elsa copied to clipboard

feat: setup telemetry events

1

I'm opening this as WIP PR to get some feedback into what other events Elsa should dispatch. My _ultimate_ end goal is to use these telemetry events to integrate [OpenTelemetry...

btkostner

Always restart non-group worker processes that exited abnormally

1

The new behaviour is less surprising and consistent with the way group consumer workers behave. Fixes #104

jtrees

Support for erlkaf built on the official kafka C library

1

[librdkafka](https://github.com/confluentinc/librdkafka) is the official Confluent kafka library (in C). The erlang/elixir library built on top of it is called [erlkaf](https://github.com/silviucpp/erlkaf). These libraries offer support for some features that are not...

tpitale

1.0.0 release

1

This issue is just a reminder to cut the 1.0.0 release.

jdenen

In a group supervision tree, workers behave as expected: If their handler triggers a crash, they are restarted and the group can continue handling messages. In a non-group supervision tree,...

jtrees

Besides other documentation changes, this commit includes all relevant documents to the generated HTML doc for HexDocs.pm and leverages on latest features of ExDoc.

kianmeng

Starting Multiple Topic Producers is Broken

2

Hi, thanks for this great library. With `{:elsa, "~> 1.0.0-rc.1"}` I'm not able to start multiple topic producers [as stated in the configuration](https://github.com/bbalser/elsa/blob/4a980b145d4c4ce2c4d6a9a4780061d2fdf442ec/lib/elsa/supervisor.ex#L44). This configuration worked as of 4410bf6c832c7736eb5206a5f1133c623dae9f8d but...

c-h-

Error before/on Elsa.Producer.ready?

1

``` 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:...

tpitale

I am working on an application that produces messages to a single topic that has 100 partitions. The workload is high, I think we would have better performance if there...

fxn

I am working on an applications that produces messages to a single topic that has 100 partitions. The workload is high, I think we would have better performance if there...

fxn