delta/python-packages/kafka-python.git/kafka/structs.py, branch ssl_set_ciphers

Add list_consumer_group_offsets()

2018-11-18T23:29:16+00:00

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` internally

2018-06-05T21:32:01+00:00

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 and send in parallel.

2017-08-07T09:34:08+00:00

Add send_list_offset_request for searching offset by timestamp (#1001)

2017-03-02T22:15:01+00:00

Always absolute_import

2016-08-03T04:36:00+00:00

Add rack to BrokerMetadata - it is always None when using MetadataRequest v0

2016-07-16T20:47:09+00:00

Split kafka.common into kafka.structs and kafka.errors

2016-04-05T16:35:44+00:00