This repository was archived by the owner on Mar 7, 2025. It is now read-only.

Commits

Commits on Jan 11, 2016

0.9.8
thieman
committed
Fix reference error
thieman
committed
Fuck you PyPi
thieman
committed
Bump fork to 0.9.6
thieman
committed
Merge pull request #1 from gamechanger/tnt-async-events
thieman
committed
Add basic test to see if registrar is working
thieman
committed
Add event registrar and events for async producer
thieman
committed
Merge pull request #496 from dpkp/idle_sleep
dpkp
committed
Pass consumer timeout to client.poll() in iterator; check timeout before iterating fetcher
Dana Powers
committed
Fix sec / millisec unit bug in KafkaConsumer._poll_once()
Dana Powers
committed
Receive all available responses in client._poll
Dana Powers
committed
If a completed future is polled, do not block
Dana Powers
committed
Avoid CPU spinnning when there are no sockets to read
Dana Powers
committed
Fix delayed_task timeout commit 45d26b6
Dana Powers
committed
Merge pull request #502 from dpkp/task_poll_timeout
dpkp
committed
Log generation and member_id in threaded consumer group test
Dana Powers
committed
Fix debug logging call in PR 500
Dana Powers
committed

Commits on Jan 10, 2016

Improve KafkaConsumer iterator loop timeouts
Dana Powers
committed
Improve cluster.ttl() readability
Dana Powers
committed
Check delayed task timeout in client.poll()
Dana Powers
committed
Remove old kafka.consumer.kafka module
Dana Powers
committed
Merge pull request #500 from dpkp/kafka-2978
dpkp
committed
KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync
Dana Powers
committed
Merge pull request #501 from dpkp/coordinator_tests
dpkp
committed
Add ConsumerCoordinator unit tests
Dana Powers
committed
Merge pull request #499 from dpkp/handle_disconnect
dpkp
committed
ConsumerCoordinator cleanups
Dana Powers
committed
Add error checking to mark_for_reassignment
Dana Powers
committed
Move ConsumerProtocol definition to kafka.coordinator.protocol
Dana Powers
committed
Refresh metadata on failed connection attempts
Dana Powers
committed
Fill out more async client unit tests
Dana Powers
committed

Commits on Jan 8, 2016

Remove errant kafka_versions('all') from 0.9 merge
Dana Powers
committed
Update README from new docs
Dana Powers
committed
Merge branch '0.9'
Dana Powers
committed
Fix KafkaClient->SimpleClient references
Dana Powers
committed