summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * Improve OffsetCommit error loggingDana Powers2015-12-291-23/+33
| * Log request failures in AbstractCoordinator._failed_requestDana Powers2015-12-291-5/+10
| * _handle_group_coordinator_response should resolve future with the coordinator idDana Powers2015-12-291-1/+1
| * Improve heartbeat loggingDana Powers2015-12-291-14/+13
| * Log as INFO: group join, leader election, partition assignmentsDana Powers2015-12-292-1/+5
| * Improve various docstringsDana Powers2015-12-293-22/+43
| * Remove extra raise and old TODO comment in coordinatorsDana Powers2015-12-292-2/+1
| * Make add_assigned_partition private(ish) in SubscriptionStateDana Powers2015-12-291-3/+3
| * Make more methods private(ish) in AbstractCoordinatorDana Powers2015-12-291-13/+13
| * Remove recursive client.poll call in ConsumerCoordinatorDana Powers2015-12-291-2/+3
| * Pass auto commit parameters from KafkaConsumer to ConsumerCoordinatorDana Powers2015-12-292-1/+3
| * Fix broken SubscriptionState.is_assigned callDana Powers2015-12-291-1/+1
| * Fix HeartbeatTask request_in_flight handlingDana Powers2015-12-291-1/+1
| * kafka.consumer.group.KafkaConsumer: 0.9 coordinator-aware consumerDana Powers2015-12-281-797/+480
| * ConsumerCoordinator (based on upstream Java client)Dana Powers2015-12-284-0/+703
| * AbstractCoordinator (modelled after upstream Java class)Dana Powers2015-12-284-0/+690
| * Define ConsumerRebalanceListener abstract classDana Powers2015-12-281-0/+84
| * Add UNKNOWN_MEMBER_ID to JoinGroupRequestDana Powers2015-12-281-0/+1
| * Add DEFAULT_GENERATION_ID and DEFAULT_RETENTION_TIME to OffsetCommitRequest_v2Dana Powers2015-12-281-0/+2
| * New class: kafka.consumer.fetcher.FetcherDana Powers2015-12-281-0/+523
| * Improvements to kafka.future.FutureDana Powers2015-12-281-8/+37
| * New class SubscriptionState, based on upstream Java clientDana Powers2015-12-281-0/+304
| * Add OffsetAndMetadata namedtupleDana Powers2015-12-281-0/+3
| * Add Message.validate_crc() methodDana Powers2015-12-281-0/+7
| * Add OffsetResetStrategy enum class to kafka.protocol.offsetDana Powers2015-12-281-0/+5
| * Use attributes on exception classes to signal retriable and invalid metadata ...Dana Powers2015-12-282-13/+33
| * Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-288-26/+26
| * New async KafkaClient, based on java NetworkClient and ConsumerClientDana Powers2015-12-282-0/+510
| * Update BrokerConnection for use with async clientDana Powers2015-12-282-39/+78
| * Add ClusterMetadata.add_group_coordinator()Dana Powers2015-12-281-0/+39
| * Rename Cluster -> ClusterMetadata; align with upstream Metadata classDana Powers2015-12-282-66/+125
| * Remove old kafka-bin directory and verify kafka-run-class.sh exists when inst...Dana Powers2015-12-181-0/+6
| * Only download/install server artifacts if bin/kafka-run-class.sh not foundDana Powers2015-12-181-5/+6
| * Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-176-154/+386
| * new 0.9 error codes plus descriptions.Zack Dever2015-12-152-10/+172
| * Drop bytes encoding of consumer group in consumer integration testDana Powers2015-12-101-1/+1
| * Remove bytes encoding for topic name in producer integration testDana Powers2015-12-101-1/+1
| * Check for no in-flight-requests in BrokerConnection.recvDana Powers2015-12-101-0/+3
| * Only log topic names (and broker metadata) in KafkaClient load_metadata debug...Dana Powers2015-12-101-1/+1
| * Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-104-25/+4
| * pylint fixesDana Powers2015-12-106-5/+7
| * Remove KafkaProtocol._decode_messageDana Powers2015-12-102-32/+2
| * Fix consumer integration test that assumed a single brokerDana Powers2015-12-101-4/+6
| * Add pylint hints to AbstractType because we cant mark a classmethod as abstractDana Powers2015-12-101-2/+2
| * Handle python3 in kafka.protocol.pickleDana Powers2015-12-101-2/+6
| * Fix zk_chroot in consumer integration kafka fixturesDana Powers2015-12-101-2/+3
| * Drop kafka_bytestringDana Powers2015-12-1014-81/+47
| * Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
| * Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-108-105/+69
| * Fix test_consumer generator/list mock, reenable testsDana Powers2015-12-101-5/+2
View Lorry Controller Status