| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Add list_consumer_group_offsets() | Jeff Widman | 2018-11-18 | 1 | -0/+1 |
| | | | | | | | | | | | | | | | | | | | | | | Support fetching the offsets of a consumer group. Note: As far as I can tell (the Java code is a little inscrutable), the Java AdminClient doesn't allow specifying the `coordinator_id` or the `partitions`. But I decided to include them because they provide a lot of additional flexibility: 1. allowing users to specify the partitions allows this method to be used even for older brokers that don't support the OffsetFetchRequest_v2 2. allowing users to specify the coordinator ID gives them a way to bypass a network round trip. This method will frequently be used for monitoring, and if you've got 1,000 consumer groups that are being monitored once a minute, that's ~1.5M requests a day that are unnecessarily duplicated as the coordinator doesn't change unless there's an error. | ||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 1 | -4/+0 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -0/+3 |
| | | | | | and send in parallel. | ||||
| * | Add send_list_offset_request for searching offset by timestamp (#1001) | charsyam | 2017-03-02 | 1 | -0/+6 |
| | | |||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 1 | -0/+2 |
| | | |||||
| * | Add rack to BrokerMetadata - it is always None when using MetadataRequest v0 | Dana Powers | 2016-07-16 | 1 | -1/+1 |
| | | |||||
| * | Split kafka.common into kafka.structs and kafka.errors | Dana Powers | 2016-04-05 | 1 | -0/+88 |
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |