Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

KafkaTimeoutError #194

Merged
merged 1 commit into from
Aug 22, 2014
Merged

KafkaTimeoutError #194

merged 1 commit into from
Aug 22, 2014

Conversation

dpkp
Copy link
Owner

@dpkp dpkp commented Aug 13, 2014

Fix bug in client.ensure_topic_exists caught by @spicavigo

@dpkp dpkp added the bug label Aug 14, 2014
dpkp added a commit that referenced this pull request Aug 22, 2014
Add KafkaTimeoutError and fix client.ensure_topic_exists
@dpkp dpkp merged commit c3df8a0 into dpkp:master Aug 22, 2014
@dpkp dpkp deleted the kafka_timeout_error branch August 28, 2014 16:31
trim21 pushed a commit to trim21/kafka-python that referenced this pull request Oct 27, 2024
test/test_consumer_integration.py::test_kafka_consumer__blocking failed
in
https://github.com/wbarnha/kafka-python-ng/actions/runs/10361086008/job/28680735389?pr=186
because it took 592ms to finish. Output from the GitHub runner attached

This commit increase TIMEOUT_MS so it is less likely to fail on GitHub
runner.

          # Ask for 5 messages, 10 in queue. Get 5 back, no blocking
          messages = []
          with Timer() as t:
              for i in range(5):
                  msg = next(consumer)
                  messages.append(msg)
          assert_message_count(messages, 5)
  >       assert t.interval < (TIMEOUT_MS / 1000.0)
  E       assert 0.5929090976715088 < (500 / 1000.0)
  E        +  where 0.5929090976715088 = <test.testutil.Timer object at 0x7f6c4b50e960>.interval

Co-authored-by: William Barnhart <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant