summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
| * Remove old kafka-bin directory and verify kafka-run-class.sh exists when ↵Dana Powers2015-12-181-0/+6
| | | | | | | | installing server artifacts
| * 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
| | | | | | | | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
| * new 0.9 error codes plus descriptions.Zack Dever2015-12-152-10/+172
| | | | | | | | | | reference: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ErrorCodes
| * 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 ↵Dana Powers2015-12-101-1/+1
| | | | | | | | debug logging
| * Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-104-25/+4
| | | | | | | | and reenable kafka.conn debug logging in tests
| * pylint fixesDana Powers2015-12-106-5/+7
| | | | | | | | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
| * 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
| |
| * Update kafka.common imports to Payloads namedtuples in test_protocolDana Powers2015-12-091-22/+24
| |
| * 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
| |
| * Default consumer integration tests should not use offset commitsDana Powers2015-12-091-2/+3
| |
| * Skip protocol tests for now -- need updatingDana Powers2015-12-091-0/+20
| |
| * Update to Payload namedtuples in consumer testsDana Powers2015-12-091-4/+4
| |
| * Skip consumer tests that cause iterator errors -- needs investigationDana Powers2015-12-091-0/+3
| |
| * Update client tests for new protocol usageDana Powers2015-12-091-74/+61
| |
| * Handle PartialMessage / ConsumerFetchSizeTooSmall in SimpleConsumerDana Powers2015-12-091-21/+24
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-099-50/+46
| |
| * 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-0722-62/+485
| |\
| * | 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
| | |
View Lorry Controller Status