summaryrefslogtreecommitdiff
path: root/test
Commit message (Collapse)AuthorAgeFilesLines
...
| * bootstrap_servers no longer required in KafkaConsumer (localhost default)Dana Powers2016-01-031-4/+0
| |
| * Disable pylint errors for py2/py3 compatibility workaroundsDana Powers2016-01-011-1/+1
| |
| * Skeleton tests for async kafka clientDana Powers2016-01-011-0/+103
| |
| * Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)Dana Powers2015-12-301-0/+2
| |
| * Catch and retry on RequestTimedOutError in producer failover testDana Powers2015-12-291-2/+4
| |
| * Rename TopicAndPartition -> TopicPartitionDana Powers2015-12-285-19/+19
| |
| * Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-35/+47
| | | | | | | | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
| * 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
| |
| * Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-102-21/+0
| | | | | | | | and reenable kafka.conn debug logging in tests
| * pylint fixesDana Powers2015-12-102-1/+2
| | | | | | | | | | | | - temporarily ignore kafka/consumer/group.py - temporarily ignore test/test_protocol.py - disable-msg deprecated; use disable= instead
| * Remove KafkaProtocol._decode_messageDana Powers2015-12-101-0/+2
| |
| * Fix consumer integration test that assumed a single brokerDana Powers2015-12-101-4/+6
| |
| * Fix zk_chroot in consumer integration kafka fixturesDana Powers2015-12-101-2/+3
| |
| * Drop kafka_bytestringDana Powers2015-12-106-33/+28
| |
| * Configure consumer group in consumer_integration testsDana Powers2015-12-101-3/+13
| |
| * Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-103-7/+7
| |
| * 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
| |
| * 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
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-095-19/+19
| |
| * Merge branch 'master' into 0.9Zack Dever2015-12-072-10/+8
| |\
| * | Fix tests broken by legacy module moveDana Powers2015-12-041-3/+3
| | |
* | | Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C)simpleDana Powers2015-12-301-0/+2
| | |
* | | Retry on FailedPayloadsError from consumer.pending() in failover testsDana Powers2015-12-181-4/+5
| | |
* | | Mock client.ensure_topic_exists in test_producer_sync_fail_on_errorproducer_new_topicDana Powers2015-12-171-10/+11
| | |
* | | Add producer integration test for SimpleProducer handling new topic creationDana Powers2015-12-161-9/+6
| | |
* | | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-105-56/+47
| |/ |/|
* | Use producer.stop() to flush messages in async producer testDana Powers2015-12-051-4/+2
| |
* | Cleanup new producer tests...async_producer_connect_errorsDana Powers2015-12-041-6/+6
|/
* new pylint disables for pylint 1.5.1Zack Dever2015-12-021-1/+1
| | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds.
* Merge pull request #420 from toddpalino/masterDana Powers2015-12-021-1/+29
|\ | | | | Initial support for consumer coordinator
| * Fix misnamed node to nodeId in testtpalino2015-07-021-1/+1
| |
| * Add missing import for ConsumerMetadataResponsetpalino2015-07-011-1/+1
| |
| * Support consumer metadata requeststpalino2015-07-011-0/+28
| | | | | | | | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator
* | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-0/+17
|\ \ | | | | | | Use unblocking io for broker aware requests
| * | Add tests. Bug fix. Rename socket_conn dict.Enrico Canzonieri2015-11-101-0/+17
| |/
* | Merge pull request #457 from saaros/block-for-number-of-messagesDana Powers2015-12-021-0/+18
|\ \ | | | | | | Consumers get_messages: allow blocking until some messages are received
| * | Consumers get_messages: allow blocking until some messages are receivedOskari Saarenmaa2015-09-181-0/+18
| |/ | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time.
* | Merge pull request #439 from chrischamberlin/fix-murmurDana Powers2015-12-021-0/+23
|\ \ | | | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.
| * | Fix translation of Java murmur2 code, fix byte encoding for Python 3.Chris Chamberlin2015-07-281-0/+23
| |/ | | | | | | | | | | Avoid further type changes when Murmur2Partitioner is passed a byte array. Change leftover-bytes logic to match the Java switch statement, and add tests to verify that partition selection matches Java implementation.
* | Merge pull request #435 from docker-hub/fix-producer-cleanup-logicDana Powers2015-12-021-0/+14
|\ \ | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-0/+14
| | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-022-2/+44
|\ \ \ | |_|/ |/| | Allow null payload for deletion feature
| * | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1
| | |
| * | Add KeyedProducer test with null payloadsViktor Shlapakov2015-06-171-0/+22
| | |
View Lorry Controller Status