summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* Minor aesthetic cleanup of partitioner testsJeff Widman2018-10-271-11/+10
|
* Remove unused ivy_root variableJeff Widman2018-10-271-1/+0
| | | | This is no longer used anywhere in the codebase
* Minor cleanup of testing docJeff Widman2018-10-271-13/+17
| | | | | | | Removed some of the hardcoded values as they are now outdated, and just pointed to where to find the current value in the code. Also some minor wordsmithing.
* Stop using deprecated log.warn()Jeff Widman2018-10-261-3/+3
| | | | I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd.
* Stop pinning `pylint`Jeff Widman2018-10-261-1/+1
| | | | | | | | | We have many deprecation warnings in the travis logs for things that are fixed in newer versions of `pylint` or `pylint`'s dependencies. Note that `pylint` >= 2.0 does not support python 2, so this will result in different versions of pylint running for python 2 vs python 3. Personally, I am just fine with this.
* Add temp workaround for upstream pylint bugJeff Widman2018-10-261-1/+3
| | | | Temporarily workaround https://github.com/PyCQA/pylint/issues/2571 so that we can stop pinning `pylint`.
* Add KafkaAdmin classRichard Lee2018-10-2410-0/+684
| | | | | | Requires cluster version > 0.10.0.0, and uses new wire protocol classes to do many things via broker connection that previously needed to be done directly in zookeeper.
* Fix sphinx urlJeff Widman2018-10-242-2/+2
| | | | | | | When I was fixing urls the other day, I noticed that sphinx hadn't added https but there was an open ticket: https://github.com/sphinx-doc/sphinx/issues/5522 Now that that is resolved, I'm updating it here.
* Prevent `pylint` import errors on `six.moves`Jeff Widman2018-10-241-0/+1
| | | | | | | | | | | | | | | | | | | | | `six.moves` is a dynamically-created namespace that doesn't actually exist and therefore `pylint` can't statically analyze it. By default, `pylint` is smart enough to realize that and ignore the import errors. However, because we vendor it, the location changes to `kafka.vendor.six.moves` so `pylint` doesn't realize it should be ignored. So this explicitly ignores it. `pylint` documentation of this feature: http://pylint.pycqa.org/en/1.9/technical_reference/features.html?highlight=ignored-modules#id34 More background: * https://github.com/PyCQA/pylint/issues/1640 * https://github.com/PyCQA/pylint/issues/223
* Vendor enum34Jeff Widman2018-10-221-0/+841
| | | | | | | | | This is needed for https://github.com/dpkp/kafka-python/pull/1540 While the usage there is trivial and could probably be worked around, I'd rather vendor it so that future code can use enums... since `enum` is already available in the python 3 stdlib, this will be easy enough to eventually stop vendoring whenever we finally drop python 2 support.
* Vendor `six` consistentlyJeff Widman2018-10-2215-30/+34
| | | | Use vendored `six`, and also `six.moves.range` rather than `xrange`
* Update remote urls: snappy, https, etcJeff Widman2018-10-225-10/+10
| | | | | Snappy URL was outdated. Similarly, many of these sites now support https.
* Bump vendored `six` to `1.11.0`Jeff Widman2018-10-221-16/+42
| | | | | | | | | Bump `six` to `1.11.0`. Most changes do not affect us, but it's good to stay up to date. Also, we will likely start vendoring `enum34` in which case https://github.com/benjaminp/six/pull/178 is needed. Note that this preserves the `kafka-python` customization from https://github.com/dpkp/kafka-python/pull/979 which has been submitted upstream as https://github.com/benjaminp/six/pull/176 but not yet merged.
* Fix typo in file nameJeff Widman2018-10-221-0/+0
|
* Support produce with Kafka record headersHeikki Nousiainen2018-09-275-18/+40
|
* Expose record headers in ConsumerRecordsHeikki Nousiainen2018-09-273-6/+13
|
* Add positive tests for headers in record encode/decodeHeikki Nousiainen2018-09-272-3/+18
|
* Expose ConsumerRebalanceListener in allBen Harack2018-09-271-1/+1
| | | | | | This solves a warning in linters like PyCharm, which warns that a line like: from kafka import ConsumerRebalanceListener is actually accessing a protected member of a class or module. Adding it to __all__ should solve this.
* Remove ConsumerTimeoutJonathan Emord2018-09-271-4/+0
|
* Clear the metrics dictionary on close. (#1569)Kishore Nallan2018-08-311-0/+2
|
* Return future from commit_offsets_async (#1560)Mike Lang2018-08-311-1/+6
|
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-314-4/+17
|
* add support for smaller topic metadata fetch during bootstrap (#1541)Ning Xie2018-08-313-6/+14
|
* Document connections_max_idle_msJeff Widman2018-06-263-0/+15
| | | | | This was added in #1068 but never documented. Fix #1497
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-0516-36/+32
| | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
* Bump version for developmentDana Powers2018-05-261-1/+1
|
* Release 1.4.31.4.3Dana Powers2018-05-263-1/+85
|
* Retain but deprecate kafka.errors.ConnectionError for compatibilityDana Powers2018-05-261-0/+4
|
* Improve connection handling when bootstrap list is invalid (#1507)Dana Powers2018-05-261-6/+3
| | | | * only perform single dns lookup for connect_blocking() * fix blocking timeout in check_version()
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-263-1/+28
|
* Document methods that return NoneJeff Widman2018-05-231-0/+3
| | | | | If a valid broker in the cluster has no partitions, it will return None rather than an empty set. Similarly updated a few other methods.
* Stop shadowing `ConnectionError`Jeff Widman2018-05-238-31/+30
| | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues.
* Stop using deprecated log.warn()Jeff Widman2018-05-101-3/+3
|
* Minor doc capitalization cleanupJeff Widman2018-04-241-15/+15
|
* Force lz4 to disable Kafka-unsupported block linking when encoding (#1476)Michael P. Nitowski2018-04-181-1/+13
|
* Skip flakey SimpleProducer testDana Powers2018-04-181-0/+1
|
* Added AlterConfigs and DescribeConfigs apis (#1472)Stephen SORRIAUX2018-04-181-1/+96
|
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-189-15/+136
|
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-184-8/+75
|
* Always acquire client lock before coordinator lock to avoid deadlocks (#1464)Dana Powers2018-04-181-59/+64
|
* Improve BrokerConnection initialization (#1475)Rômulo Rosa Furtado2018-04-151-1/+1
|
* Fix CreatePartitionsRequest_v0 (#1469)Stephen SORRIAUX2018-04-051-1/+1
|
* Adds add_callback/add_errback example to docs (#1441)Berkodev2018-03-291-0/+12
|
* Heartbeat thread start / closeDana Powers2018-03-231-2/+4
|
* Change levels for some heartbeat thread loggingDana Powers2018-03-231-3/+3
|
* Fix KafkaConsumer docstring for request_timeout_ms default (#1459)Dana Powers2018-03-233-5/+5
|
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-237-34/+42
|
* Check for immediate failure when looking up coordinator in heartbeat thread ↵Dana Powers2018-03-231-1/+5
| | | | (#1457)
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-222-0/+9
|
* Bump version for developmentDana Powers2018-03-101-1/+1
|
View Lorry Controller Status