kafka_ex
kafka_ex copied to clipboard
kafkaex
Kafka client library for Elixir
This is a follow-up to #183. `KafkaEx.latest_offset/3` and `KafkaEx.earliest_offset/3` both return type `[OffsetResponse.t] | :topic_not_found`. On the other hand, functions like `KafkaEx.fetch/3` and `KafkaEx.stream/3` take an `offset` option that expects...
This is inspired by the conversation in #157. There are some places where the log level might need to be tweaked or the logging could be removed completely. We may...
We currently run CI against only the 0.9.0 server in travis, we should have travis run builds for the 0.8.0 and 0.8.2 servers
Piece meal from https://github.com/kafkaex/kafka_ex/issues/67 Specification can be found at: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ListGroupsRequest
Piece meal from https://github.com/kafkaex/kafka_ex/issues/67 Specification can be found at: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-DescribeGroupsRequest
Add a user-configurable `:shutdown` to `GenConsumer`'s child_spec. Addresses #434, if `do_some_job`, from the referred issue, is either synchronous or async. Not sure if the change covers the case of a...
Due to the changes to the ssl module to [provide safer defaults](https://www.erlang.org/blog/otp-26-highlights/#ssl-safer-defaults), `kafka_ex` will fail to connect to a broker even when `use_ssl` is `false`. ```elixir {:error, {:options, :incompatible, [verify:...
I am getting some typespec errors because Dialyzer doesn't like `Message{timestamp: nil}`. This [timestamp](https://github.com/kafkaex/kafka_ex/pull/364#pullrequestreview-1324793257) was added as a required key. Shouldn't it be optional, so that it can be skipped...
