summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Handle PartialMessage / ConsumerFetchSizeTooSmall in SimpleConsumerDana Powers2015-12-091-21/+24
* Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-094-31/+27
* Refactor KafkaClient to use BrokerConnections and new Request/Response structsDana Powers2015-12-091-148/+131
* Exception handling cleanup in BrokerConnection (also catch struct.errors in r...Dana Powers2015-12-091-4/+4
* Add client_id and correlation_id to BrokerConnection constructor kwargsDana Powers2015-12-091-3/+7
* Change KafkaProtocol to encode/decode Structs, not bytesDana Powers2015-12-092-252/+112
* Support pickling of Structs -- _encode_self instance method needs some magicDana Powers2015-12-092-0/+26
* Return PartialMessage object in MessageSet.decode if message is truncated by ...Dana Powers2015-12-091-3/+10
* Fallback to simple repr() in Schema.repr()Dana Powers2015-12-091-7/+10
* Fix BytesIO import in kafka.protocol.messageDana Powers2015-12-091-1/+3
* Fix _mp_consume queue variable name conflictDana Powers2015-12-091-2/+2
* Handle special __init__ signature in Message decode()Dana Powers2015-12-091-0/+8
* Handle decoding partial messages in MessageSet - caused by FetchRequest max_b...Dana Powers2015-12-091-6/+24
* Merge branch 'master' into 0.9Zack Dever2015-12-074-17/+34
|\
| * Release 0.9.5v0.9.5Dana Powers2015-12-071-1/+1
| * Merge pull request #426 from ucarion/ucarion-kafkaconsumer-closeDana Powers2015-12-061-0/+4
| |\
| | * Add KafkaConsumer#closeUlysse Carion2015-07-071-0/+4
| * | Log deprecation warning for timeout argument in Producer.stop()Dana Powers2015-12-061-3/+7
| * | Producer.stop() now blocks until async thread completes (drop confusing timeo...async_producer_stopDana Powers2015-12-051-7/+12
| * | Revert broken send_produce_request try/except from PR 467 (resps=None)Dana Powers2015-12-051-5/+1
| * | Fix requestId handling in send_broker_aware_requestDana Powers2015-12-041-2/+2
| * | client.reinit() can raise an exception; catch in async producerDana Powers2015-12-041-2/+10
* | | few small cleanupsZack Dever2015-12-043-8/+2
* | | administration api schemasZack Dever2015-12-041-0/+44
* | | group membership api schemasZack Dever2015-12-041-0/+108
* | | Add size and correlation id decoding to try/except block in BrokerConnectionDana Powers2015-12-041-4/+5
* | | Add comment re bytes offset tracking in MessageSet decode()Dana Powers2015-12-041-1/+1
* | | Unfinished kafka.consumer.group commitDana Powers2015-12-041-0/+883
* | | Add simple Cluster class to manage broker metadataDana Powers2015-12-041-0/+91
* | | BrokerConnection:Dana Powers2015-12-041-11/+65
* | | Recursive repr, display all field names and values for StructsDana Powers2015-12-044-5/+27
* | | Use simply counting instead of buffer.tell() -- socket.makefile does not supp...Dana Powers2015-12-041-2/+4
* | | Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-046-58/+101
* | | Rework protocol type definition: AbstractType, Schema, StructDana Powers2015-12-0410-371/+461
* | | Fix __init__ legacy relative module importDana Powers2015-12-041-1/+1
* | | Switch crc32 back to signed integer -- this is consistent with protocol encod...Dana Powers2015-12-042-3/+9
* | | Fix tests broken by legacy module moveDana Powers2015-12-041-0/+2
* | | Move ProduceRequest to kafka.protocol.produceDana Powers2015-12-042-54/+59
* | | Basic 0.8 Request protocol classes, with encoding onlyDana Powers2015-12-041-0/+355
* | | Add base api type classes w/ encoders in kafka.protocol.typesDana Powers2015-12-041-0/+55
* | | Rename kafka.protocol -> kafka.protocol.legacyDana Powers2015-12-042-0/+6
|/ /
* | new pylint disables for pylint 1.5.1Zack Dever2015-12-022-2/+2
* | Merge pull request #420 from toddpalino/masterDana Powers2015-12-023-6/+197
|\ \
| * | Support consumer metadata requeststpalino2015-07-013-6/+197
| |/
* | Fix python3 / python2 comments re queue/QueueDana Powers2015-12-022-10/+10
* | Add Murmur2Partitioner to kafka __all__ imports - fix issue 471Dana Powers2015-12-021-1/+1
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-022-18/+35
|\ \
| * | Add tests. Bug fix. Rename socket_conn dict.Enrico Canzonieri2015-11-101-7/+7
| * | Unblocking broker aware requestEnrico Canzonieri2015-11-102-18/+35
* | | Merge pull request #467 from bschopman/masterDana Powers2015-12-022-2/+9
|\ \ \
View Lorry Controller Status