ruby-kafka
ruby-kafka copied to clipboard
Set timeout period to wait for messages
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