delta/python-packages/kafka-python.git/kafka, branch message_set_encode_size

Always encode size with MessageSet

2016-07-17T19:55:42+00:00

Avoid buffer overread when compressing messageset in KafkaProducer

2016-07-17T19:08:57+00:00

Expand consumer.fetcher comment re comparing request / response offsets

2016-07-17T19:00:23+00:00

Delete KafkaConnection class (#769)

2016-07-17T18:56:17+00:00

KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770 / #594)

2016-07-17T18:44:01+00:00

Explicit format string argument indices for python 2.6 compatibility

2016-07-17T17:44:32+00:00

Simplify RecordMetadata; short circuit callbacks (#768)

2016-07-17T17:17:10+00:00

  Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization
  Minor optimization: inline check for no callbacks

KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)

2016-07-17T16:29:45+00:00

KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)

2016-07-17T15:37:44+00:00

KAFKA-2832: Add a consumer config option to exclude internal topics (#765)

2016-07-17T15:37:15+00:00

  Use exclude_internal_topics config in KafkaConsumer to avoid subscribe patterns matching internal topics
  Raise error during rebalance if subscribed topics are not authorized