Takeshi Arabiki

Cool.io::TCPServer continues to receive data even if its close method is called

2

I expect `Cool.io::TCPServer` to stop receiving data after `Cool.io::TCPServer#close` is called, but it continues to receive data. Is this behavior expected? Here is a reproducible code: ```ruby require 'socket' require...

The example "consuming messages using the batch API" sometimes gets stuck as follows, and the reason might be `Queue#pop` waits for a message unlimitedly. * https://app.circleci.com/pipelines/github/zendesk/ruby-kafka/233/workflows/b80d0db8-1334-49e2-abf9-9d51580c42bc/jobs/6931 * https://app.circleci.com/pipelines/github/zendesk/ruby-kafka/232/workflows/a612607f-f20d-4bb0-b6b4-47e184a26474/jobs/6920 * https://app.circleci.com/pipelines/github/zendesk/ruby-kafka/230/workflows/fedf26e8-22af-4deb-878d-aa6c5fc5ae6f/jobs/6895

CI sometimes times out due to "log writing failed. deadlock; recursive locking" as follows, and it might be related to https://bugs.ruby-lang.org/issues/15360. If so, using the image "cimg/ruby:2.5.9" resolves the problem....

This PR prevents the example "create partitions" from failing like https://app.circleci.com/pipelines/github/zendesk/ruby-kafka/221/workflows/7d51470f-c102-4b30-b2e0-68c618eeb1d2/jobs/6799?invite=true#step-104-122. As there is a time lag for Kafka's metadata to be updated, `Kafka::Client#partitions_for` is needed to be executed until...

This PR resolves https://github.com/zendesk/ruby-kafka/issues/941. As the coordinator waits for each member to rejoin when rebalancing the group, the timeout of join request should be greater than rebalance_timeout. > rebalance_timeout_ms :...

Join request timeout doesn't consider rebalance_timeout

1

* Version of Ruby: ruby 3.0.2p107 (2021-07-07 revision 0db68f0233) [x86_64-darwin20] * Version of Kafka: 6.1.1-ccs (Commit:c209f70c6c2e52ae) * Version of ruby-kafka: 1.4.0 (555281eb407c9fc7aa08e7ebedc950959ad4ac5f) ###### Steps to reproduce ```ruby require 'logger' require...

Use "insert 0" instead of "use" in README

1

The status code won't be correct when it is changed in `rescue_from` block, so use "insert 0" instead of "use" in README. I describe more details below. ## Before ```ruby...

This PR resolves https://github.com/aserafin/grape_logging/issues/53.

We use `GrapeLogging::Middleware::RequestLogger` like below: ```ruby class MyApi < Grape::API use GrapeLogging::Middleware::RequestLogger, { include: [GrapeLogging::Loggers::FilterParameters.new], } post {} end ``` If we send a request whose body includes invalid byte...

`Concurrent::RejectedExecutionError` can occur in the case like below: 1. polling thread 1: Fetch records (`@executor.remaining_capacity = 10`) 2. polling thread 2: Fetch records (`@executor.remaining_capacity = 10`) 3. polling thread 1:...