Issues
- 2
Ruby Kafka Issues with MessageBufferOverFlow
#973 opened by PechiMuthuJ - 5
bottleneck in producing messages?
#872 opened by katpadi - 2
python: rdkafka_roundrobin_assignor.c:97: rd_kafka_roundrobin_assignor_assign_cb: Assertion `next < rd_list_cnt(&eligible_topic-> members)' failed
#883 opened by benjaminelkrieff - 3
Consuming from topic with zstd compression
#889 opened by rkrage - 2
- 1
Option to set cipher suites when connecting to kafka
#902 opened by mdost - 4
Allow AsyncProducer to delegate error handling
#921 opened by ferrous26 - 2
Max_wait_time same as max.interval.poll.ms
#912 opened by Ravinderbaid - 5
Support Reporting Metrics to OpenTelemetry
#927 opened by gfonseca-tc - 1
- 1
Support for KAFKA-4148 / KIP-79 / search offsets by timestamp in Consumer
#934 opened by rishabhsairawat - 1
- 2
- 12
MSK IAM: add support for AssumeRole auto refresh
#944 opened by hnaoto - 2
Kafka emit to Datadog is broken under ruby 3
#945 opened by nevinera - 1
- 1
- 1
- 1
- 4
- 7
Add support for using ssl_ca_cert as string
#975 opened by davkim - 2
Help: Kafka topics are deleted automatically after sudo systemctl stop kafka is done.
#962 opened by mai1x9 - 1
Long term plan for ruby-kafka
#963 opened by sadhu89 - 1
parameter "ssl_verify_hostname" is not used
#958 opened by phuonghuynguyen - 1
- 2
EOFError when connecting with SCRAM authentication
#935 opened by sandbardev - 0
What is connection_builder in ruby kafka?
#926 opened by SKG0811 - 1
Update latest release on repo landing page.
#929 opened by YadhuPrakash - 1
Using snappy compression requires adding a dependency on the `snappy` gem to your Gemfile. (LoadError)
#920 opened by jedrekdomanski - 1
max_buffer_bytesize for async_producer
#913 opened by alan-sapaad - 0
Protobuf support?
#915 opened by shotai - 0
- 6
Few Partitions of topic are very slow intermittently
#891 opened by sathia27 - 3
Add a after_batch hook on the `each_message` method
#892 opened by arthurnn - 1
cuyhoik=
#894 opened by lisamowagner - 1
"}|++
#895 opened by lisamowagner - 2
Rubydoc.info is missing
#882 opened by fjbotto - 4
Time.at(Float) is quite slow
#844 opened by eregon - 1
Ruby script stalls at @offset_manager.commit_offsets_if_necessary in consumer.rb
#864 opened by rishabhsinghvi - 5
[BUG] Consumer in consumer group stoped with no info
#851 opened by archfish - 1
Batch processing giving error '' uninitialized constant SearchIndex (NameError)"
#879 opened by shan2k6 - 0
not getting max_buffer_size to work
#871 opened by steveburkett - 2
Requesting new release
#865 opened by hasghari - 3
[Bug?] Trying to join a consumer group indefinitely
#854 opened by PChambino - 1
Unable to start consumer with remote Kafka Broker, keep getting Kafka::InvalidReplicationFactor error
#861 opened by rishabhsinghvi - 3
- 4
Error sending heartbeat: Kafka::RebalanceInProgress
#847 opened by marcoroth - 10
Retry topic subscription in a different thread?
#850 opened by fxn - 1
Is there a reason for not doing GEM release 1.2 that includes critical fixes?
#853 opened by jdevalk2 - 2