delta/python-packages/kafka-python.git/kafka/consumer, branch consumer_iterator_with_poll github.com: mumrah/kafka-python.git Add internal update_offsets param to consumer poll(); default to new iterator 2019-09-28T23:33:01+00:00 Dana Powers dana.powers@gmail.com 2019-09-28T17:48:27+00:00 9248b7bb14e72d81a3f29e54bd0719bc27e20d2c 






Wrap consumer.poll() for KafkaConsumer iteration
2019-09-28T23:33:01+00:00

Dana Powers
dana.powers@gmail.com

2019-09-15T23:30:54+00:00

5a653346a55d8ce3780833cbbd96735e40e74927












Reduce internal client poll timeout for consumer iterator interface (#1824)
2019-08-16T18:04:10+00:00

Dana Powers
dana.powers@gmail.com

2019-08-16T18:04:10+00:00

5bc25292b8bb5b20ba2fff481fdc77b9909d0831

More attempts to address heartbeat timing issues in consumers, especially with the iterator interface. Here we can reduce the `client.poll` timeout to at most the retry backoff (typically 100ms) so that the consumer iterator interface doesn't block for longer than the heartbeat timeout.




More attempts to address heartbeat timing issues in consumers, especially with the iterator interface. Here we can reduce the `client.poll` timeout to at most the retry backoff (typically 100ms) so that the consumer iterator interface doesn't block for longer than the heartbeat timeout.






Fix minor typo (#1865)
2019-07-14T15:22:10+00:00

Carson Ip
carsonip@users.noreply.github.com

2019-07-14T15:22:10+00:00

eed25fc36110b12ec370b4d0e332173abce9076f












Update link to upstream Kafka docs
2019-07-11T18:49:56+00:00

Jeff Widman
jeff@jeffwidman.com

2019-07-11T18:49:56+00:00

fb87a353d99b3271105d0941f39ee64bf2ab6858

the new consumer is now the standard consumer, so they dropped the `new_` from the anchor




the new consumer is now the standard consumer, so they dropped the `new_` from the anchor






Update docs for api_version_auto_timeout_ms (#1812)
2019-05-24T07:15:58+00:00

Jeff Widman
jeff@jeffwidman.com

2019-05-24T06:16:55+00:00

cee4d17df7858439e0dbdf3914ca0107e080af7d

The docs for `api_version_auto_timeout_ms` mention setting
`api_version='auto'` but that value has been deprecated for years in
favor of `api_version=None`.

Updating the docs for now, and will remove support for `'auto'` in next
major version bump.





The docs for `api_version_auto_timeout_ms` mention setting
`api_version='auto'` but that value has been deprecated for years in
favor of `api_version=None`.

Updating the docs for now, and will remove support for `'auto'` in next
major version bump.







Fix typo in _fetch_all_topic_metadata function (#1809)
2019-05-23T16:07:11+00:00

Brian Sang
sang.bri@gmail.com

2019-05-23T16:07:11+00:00

1a0f2973190e2bb60909bfcd28e5ad8e732e918e












Make partitions_for_topic a read-through cache (#1781)
2019-05-23T06:54:14+00:00

Brian Sang
sang.bri@gmail.com

2019-05-23T06:54:14+00:00

1f73287e890a4c68f240dcc8b6966de1e62b65cc

If the cluster metadata object has no info about the topic, then issue a blocking metadata call to fetch it.




If the cluster metadata object has no info about the topic, then issue a blocking metadata call to fetch it.






Update link to kafka docs
2019-05-17T22:14:13+00:00

Jeff Widman
jeff@jeffwidman.com

2019-05-17T22:14:13+00:00

1b6c9c76bcf753c4dd28dc2d865d6d43246cf4af

Now that the old zookeeper consumer has been completely deprecated/removed, these are no longer the "new consumer configs" but rather simply the "consumer configs"




Now that the old zookeeper consumer has been completely deprecated/removed, these are no longer the "new consumer configs" but rather simply the "consumer configs"






Update sasl configuration docstrings
2019-03-24T01:01:18+00:00

Dana Powers
dana.powers@gmail.com

2019-03-24T01:01:18+00:00

ce9c1d2e2b8d85b2f6c3b2a2ebd280246cfea07f