delta/python-packages/kafka-python.git/kafka/consumer/subscription_state.py, branch skip_integration_tests github.com: mumrah/kafka-python.git KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364) 2018-02-03T00:36:30+00:00 Dana Powers dana.powers@gmail.com 2018-02-03T00:36:30+00:00 618c5051493693c1305aa9f08e8a0583d5fcf0e3 






Add method to ensure a valid topic name (#1238)
2017-10-07T21:43:29+00:00

Niklas Mollenhauer
nikeee@users.noreply.github.com

2017-10-07T21:43:29+00:00

30ba2c1dbd22eff5f202bbbf2ecd8b42d242b1b0












Fix raise exception from SubscriptionState.assign_from_subscribed (#960)
2017-02-03T17:45:57+00:00

Petr Šebek
petrsebek1@gmail.com

2017-02-03T17:45:57+00:00

ce1bdee2ecda6279f062e1bdafa07fbbf747845e












Use six.string_types for topic type check in #824
2016-11-20T20:44:55+00:00

Dana Powers
dana.powers@gmail.com

2016-11-20T20:44:55+00:00

c4a6e1aa68fc48dd589ff64e1247d2886ccfa3fd












Raise exception if given a bad topic name (#824)
2016-11-20T20:43:26+00:00

Samuel Taylor
github@samueltaylor.org

2016-11-20T20:43:26+00:00

5ad6f52a802c38b97e1fe4f6afa711ff1415d02f












Merge pull request #785 from dpkp/six
2016-08-02T01:14:25+00:00

Dana Powers
dana.powers@gmail.com

2016-08-02T01:14:25+00:00

99891adfa0b4e6baa0877c50e7fb2d3951ec5b39

Vendor python module six; move selectors34 and socketpair under kafka.vendor




Vendor python module six; move selectors34 and socketpair under kafka.vendor






Fix offset fetch when partitions are manually assigned (#786)
2016-08-01T23:30:03+00:00

Dana Powers
dana.powers@gmail.com

2016-08-01T23:30:03+00:00

ec286c9fb6a49b20a3cdce473b03b55fe43d0e43












Vendor six 1.10.0
2016-08-01T21:47:40+00:00

Dana Powers
dana.powers@gmail.com

2016-08-01T16:45:39+00:00

51b3d311f3930d9bb86877ca235156eb9d46763c












Use explicit subscription state flag to handle seek() during message iteration
2016-07-08T22:06:37+00:00

Dana Powers
dana.powers@gmail.com

2016-07-08T22:06:37+00:00

7b5ade10a5f4197ec19fce5d77484100c6dc1273












Update imports from kafka.common -> kafka.errors / kafka.structs
2016-04-05T16:35:45+00:00

Dana Powers
dana.powers@gmail.com

2016-04-05T16:34:48+00:00

5a14bd8c947251d1a8f848175cc3cf2b07af3411