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