summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
...
| * Drop kafka_bytestringDana Powers2015-12-108-48/+19
| |
| * Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-105-98/+62
| |
| * Add next_correlation_id_recv + send helper methods to BrokerConnectionDana Powers2015-12-091-0/+8
| |
| * Support requests that do not expect a response in BrokerConnectionDana Powers2015-12-091-2/+3
| |
| * 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 ↵Dana Powers2015-12-091-4/+4
| | | | | | | | recv)
| * 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
| | | | | | | | | | - add Payload to kafka.common Request/Responses namedtuples - OffsetFetch and OffsetCommit still need to be converted
| * 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
| | | | | | | | max_bytes
| * 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 ↵Dana Powers2015-12-091-6/+24
| | | | | | | | max_bytes
| * Merge branch 'master' into 0.9Zack Dever2015-12-074-17/+34
| |\
| * | 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
| | | | | | | | | | | | | | | | | | separate send / recv in BrokerConnection improve connection and error handling use different read and write fds for py3
| * | 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 ↵Dana Powers2015-12-041-2/+4
| | | | | | | | | | | | support tell()
| * | 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 ↵Dana Powers2015-12-042-3/+9
| | | | | | | | | | | | encoding spec
| * | 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
| | |
* | | Fix typo in docblockMatthias Endler2015-12-181-1/+1
| | |
* | | Handle new topic creation / LeaderNotAvailableError in initial ↵Dana Powers2015-12-161-1/+1
| | | | | | | | | | | | SimpleProducer.send_messages call
* | | Fix _mp_consume queue variable name conflictDana Powers2015-12-091-2/+2
| | |
* | | Bump version for development of next releaseDana Powers2015-12-091-1/+1
| |/ |/|
* | 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#close
| * | 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 ↵async_producer_stopDana Powers2015-12-051-7/+12
| | | | | | | | | | | | timeout arg)
* | | 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
| |/ |/|
* | new pylint disables for pylint 1.5.1Zack Dever2015-12-022-2/+2
| | | | | | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds.
View Lorry Controller Status