kafka_ex
kafka_ex copied to clipboard
kafkaex
Kafka client library for Elixir
Hi there, My kafka consumers are not showing up on the strimzi kafka grafana dashboard but I can confirm they are consuming data without any issues. According to https://github.com/strimzi/strimzi-kafka-operator/discussions/5341#discussioncomment-3355975 `Kafka...
To my understanding, when we produce a message with Topic A, the client will call server for metadata of the topic [here](https://github.com/kafkaex/kafka_ex/blob/5723a4719dbfa67bdb7024ee6e00cda5c9246937/lib/kafka_ex/server.ex#L591). However, we can see sometimes (not always), the...
It's been quite a while since 0.12.1 was released and there seem to have been a couple of changes merged to the main branch (https://github.com/kafkaex/kafka_ex/pull/414 in particular). Is there any...
Kafka protocol >= 0.11 allows to send arbitrary headers [{key, value}] along with the message payload. This is very useful for metadata as schema version, origin, etc.
We're using kafka_ex as the driver for a 6 broker kafka cluster. It's integrated in an Erlang app. We also introduced worker_pool. When reviewing logs, I found this: `=ERROR REPORT====`...
Hey, I'm currently experiencing a problem that if Kafka_ex request timeout without broker response, the whole process crashed. Wonder is there a way / config to let kafka_ex application and...
Prompted by #421 and #422 - I took a whack at writing some github actions to run the test suite and added some additional checks. I've split the integration tests...
Fixes an issue when having a key and the topic does not exist. Previously this would cause the genserver to terminate: mfa=:gen_server.error_info/7 [error] GenServer :greeks_worker_4 terminating ** (ArithmeticError) bad argument...
**Versions:** OS: Ubuntu 16.04 LTS Erlang/OTP: 22.2.2 Elixir: 1.9.4 Kafka_ex: 0.11.0 Kafka cluster (AWS MSK): 2.2.1 Kafka topic (usual setup): 1 topic with 9 partitions **Overview:** We run our setup...
