delta/python-packages/kafka-python.git/kafka/common.py, branch struct-pre-compilation github.com: mumrah/kafka-python.git Always absolute_import 2016-08-03T04:36:00+00:00 Dana Powers dana.powers@gmail.com 2016-08-03T04:36:00+00:00 c693709aaf9e292c8614b9ab345d3322d4f71caa 






Split kafka.common into kafka.structs and kafka.errors
2016-04-05T16:35:44+00:00

Dana Powers
dana.powers@gmail.com

2016-04-05T15:59:02+00:00

221f56d8a05cdc2d37f85018e4af352b4b2a95c5












Mark old kafka.common structs as Deprecated; remove unused TopicMetadata
2016-02-16T00:12:39+00:00

Dana Powers
dana.powers@gmail.com

2016-02-16T00:11:05+00:00

7eeba0d15f977eb3b17a34b8ed57d75520c7aa60












Small KafkaClient.check_version() improvements
2016-01-26T00:30:32+00:00

Dana Powers
dana.powers@rd.io

2016-01-25T23:59:35+00:00

a667a4b3be03ed75cd225223678bdc6fda0a8016

  - filter connection failure logging during version check
  - raise UnrecognizedBrokerVersion if we cant id broker





  - filter connection failure logging during version check
  - raise UnrecognizedBrokerVersion if we cant id broker







Use ConnectionError rather than new DisconnectError
2015-12-30T01:48:10+00:00

Dana Powers
dana.powers@rd.io

2015-12-30T01:48:10+00:00

c549a2b403900c0f305f67224dc13356aa65934c












AbstractCoordinator (modelled after upstream Java class)
2015-12-28T23:18:43+00:00

Dana Powers
dana.powers@rd.io

2015-12-28T23:05:08+00:00

baab076c7e70a721d958f588c4199acbaae41481

 - Heartbeat class manages HeartbeatRequest / Response state
 - metrics are still TODO





 - Heartbeat class manages HeartbeatRequest / Response state
 - metrics are still TODO







Add OffsetAndMetadata namedtuple
2015-12-28T21:45:25+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T17:13:58+00:00

87f0181b2c6c51318a6f950e9478d14a7efe963f












Use attributes on exception classes to signal retriable and invalid metadata errors
2015-12-28T21:45:23+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T09:43:57+00:00

d2af5b37ce53fcde6e9f3ee1b587c1ee1de19d2c












Rename TopicAndPartition -> TopicPartition
2015-12-28T21:44:29+00:00

Dana Powers
dana.powers@rd.io

2015-12-21T09:37:25+00:00

c9e6f17e42e410adfe583d987c516149bdcdcdae












New async KafkaClient, based on java NetworkClient and ConsumerClient
2015-12-28T21:44:25+00:00

Dana Powers
dana.powers@rd.io

2015-12-20T18:27:52+00:00

fd1801907f85ac7686b9452c08ae908c3a88cd51

 - Support async client bootstrap retries after exponential backoff
 - Attempt to finish_connect if still connecting in KafkaClient.ready(node_id)
 - Run full async loop while waiting for futures in KafkaClient.poll()
 - Add more fallbacks to KafkaClient.least_loaded_node; worst case, retry boostrap





 - Support async client bootstrap retries after exponential backoff
 - Attempt to finish_connect if still connecting in KafkaClient.ready(node_id)
 - Run full async loop while waiting for futures in KafkaClient.poll()
 - Add more fallbacks to KafkaClient.least_loaded_node; worst case, retry boostrap