Issues
- 5
Emit Telemetry events
#385 opened by stephanos - 2
Investigate alternatives to travis-ci
#421 opened by dantswain - 8
Add kafka headers to messages, producer and consumer
#397 opened by matreyes - 0
`ssl_options` require configuration even when `use_ssl` is `false` in Erlang/OTP-26
#485 opened by leemeichin - 4
Consumer timeouts
#425 opened by ulutomaz - 7
:unsupported_version error
#476 opened by eddy147 - 0
- 3
Create a new release with recent changes?
#466 opened by jfmyers9 - 1
- 1
- 7
Feature Request: Distributed Consumers
#472 opened by BlueCollarChris - 0
- 1
- 1
record headers does not work with fetch v3
#465 opened by yingyingtang-brex - 2
badmatch in NetworkClient
#449 opened by TC-aLi - 2
- 3
- 18
Timeout errors
#389 opened by andrielfn - 1
KafkaEx.ConsumerGroup starting suerpvisor tree - Supervisor.Spec.supervisor/2 is deprecated.
#439 opened by cdesch - 1
encountered nonexistent topic when Kafka restarts
#448 opened by mammenj - 0
Error using Kayrock with SSL
#441 opened by joechiarella - 7
Starting a standalone consumer
#429 opened by arjun289 - 4
Create 0.12 Release
#417 opened by markusfeyh - 0
How to gracefully shutdown consumer group?
#434 opened by lessless - 1
snappy compatibility
#426 opened by dch - 4
username and password support
#428 opened by pulzzedavid - 2
Host gets hashed in metadata?
#427 opened by pulzzedavid - 5
- 5
- 4
Support for Kafka versions 2.0.0+
#415 opened by arjun289 - 1
{:error, :no_broker} when producing a message
#412 opened by mustela - 1
KafkaEx.stream timing out trying to fetch more messages even with no_wait_at_logend
#357 opened by yogodoshi - 3
Support current kafka compression types
#361 opened by technomage - 10
- 5
Wrong contract for KafkaEx.create_topics
#410 opened by VitorTrin - 2
Kayrock based client doesn't handle tcp_closed
#381 opened by kennethito - 3
Default partitioner does not match Java client
#398 opened by mjparrott - 12
Argument Error :erlang.hd([]) on Elixir 1.8.1
#346 opened by brianlow - 3
Choose partition based on key
#365 opened by lhrolim - 1
- 4
Possible to configure batch.size for kafka produce/ Question about lacking producer in kafka_ex
#376 opened by chen116 - 0
- 1
- 2
how to use KafkaEx.create_topics/2
#363 opened by chen116 - 2
No able to use kafka_version: "0.10.1" in config
#353 opened by chen116 - 2
Produce request with acks = -1 produces an error
#352 opened by hackmad - 5
Consumers do not create topics automatically
#340 opened by skateinmars - 1
receiving unhandled :EXIT message due to calling Task.async from GenConsumer
#336 opened by jasongoodwin - 1
Support dynamic connections
#334 opened by technomage - 1
Got Issue with initial connection
#330 opened by haluan