ruby-kafka icon indicating copy to clipboard operation
ruby-kafka copied to clipboard

Set timeout period to wait for messages

Open abicky opened this issue 2 years ago • 0 comments

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

abicky avatar Jun 11 '22 12:06 abicky