delta/python-packages/kafka-python.git - github.com: mumrah/kafka-python.git

	Commit message (Expand)	Author	Age	Files	Lines
*	Args are optional in BrokerResponseError strkafka_error_str	Dana Powers	2016-11-18	1	-3/+3
*	Revert consumer iterators from max_poll_records (#856)	Dana Powers	2016-10-24	2	-14/+180
*	Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)	Dana Powers	2016-10-22	2	-12/+11
*	Bugfix on max_poll_records - TypeError: object of type NoneType has no len()	Dana Powers	2016-10-04	1	-1/+1
*	KAFKA-3007: KafkaConsumer max_poll_records (#831)	Dana Powers	2016-09-28	2	-240/+120
*	Update Partitioners for use with KafkaProducer (#827)	barrotsteindev	2016-09-28	3	-24/+77
*	Monkeypatch max_in_flight_requests_per_connection when checking broker versio...	Dana Powers	2016-09-28	1	-6/+11
*	Fix message timestamp_type (#828)	Josh Yudaken	2016-09-15	1	-1/+4
*	Added ssl_password config option to KafkaProducer class, identical to… (#830)	kierkegaard13	2016-09-15	2	-0/+5
*	from kafka import ConsumerRebalanceListener, OffsetAndMetadata	Dana Powers	2016-09-04	1	-1/+2
*	Fix quota violation exception message (#809)	Dana Powers	2016-08-20	1	-4/+4
*	Improve KafkaProducer docstring re retries config	Dana Powers	2016-08-20	1	-3/+5
*	Add comment for round robin partitioner with different subscriptions	Dana Powers	2016-08-20	1	-0/+15
*	Bump version for development	Dana Powers	2016-08-11	1	-1/+1
*	Patch Release 1.3.11.3.1	Dana Powers	2016-08-08	1	-1/+1
*	HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reco...	Dana Powers	2016-08-08	1	-11/+15
*	Bump version for development	Dana Powers	2016-08-04	1	-1/+1
*	Release 1.3.01.3.0	Dana Powers	2016-08-04	1	-1/+1
*	Drain pending requests to the coordinator before initiating group rejoin (#798)	Dana Powers	2016-08-04	1	-0/+8
*	Send combined size and payload bytes to socket to avoid potentially split pac...	Dana Powers	2016-08-04	1	-6/+6
*	Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...	Dana Powers	2016-08-04	1	-4/+4
*	Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics	Dana Powers	2016-08-04	3	-8/+17
*	Instrument metrics in BrokerConnection	Dana Powers	2016-08-04	3	-17/+125
*	Treat metric_group_prefix as config in KafkaConsumer	Dana Powers	2016-08-04	4	-14/+13
*	Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient	Dana Powers	2016-08-04	1	-1/+1
*	Remove unused import from kafka.conn	Dana Powers	2016-08-04	1	-1/+1
*	Add BrokerConnection docstring with configuration parameters	Dana Powers	2016-08-04	1	-0/+65
*	Add connection-count to KafkaClient metrics	Dana Powers	2016-08-04	1	-3/+12
*	Add connection-creation-rate / connection-close-rate to KafkaClientMetrics	Dana Powers	2016-08-04	1	-0/+13
*	Fix misspelling of "password" (#793)	Samuel Taylor	2016-08-04	3	-3/+3
*	Ignore socket.error when checking for protocol out of sync prior to socket cl...	Dana Powers	2016-08-03	1	-4/+7
*	minor tweaks to get authentication working	Lars Jørgen Solberg	2016-08-03	1	-8/+7
*	Use callbacks for sasl handshake request / response	Dana Powers	2016-08-03	1	-59/+62
*	implement sasl PLAIN mechanism	Lars Jørgen Solberg	2016-08-03	6	-4/+176
*	Always absolute_importabsolute_import	Dana Powers	2016-08-02	55	-0/+113
*	Rename partition_assignment -> assignment in MemberMetadata for consistency	Dana Powers	2016-08-02	1	-1/+1
*	Clarify api_version=str deprecation warning	Dana Powers	2016-08-02	2	-2/+2
*	Metadata with_partitions() (#787)	Dana Powers	2016-08-01	1	-1/+20
*	Merge pull request #785 from dpkp/six	Dana Powers	2016-08-01	24	-27/+901
\|\
\| *	Vendor six 1.10.0six	Dana Powers	2016-08-01	23	-25/+899
\| *	Move kafka.socketpair to kafka.vendor.socketpair	Dana Powers	2016-08-01	2	-1/+1
\| *	Move kafka.selectors34 to kafka.vendor.selectors34	Dana Powers	2016-08-01	3	-1/+1
* \|	Fix offset fetch when partitions are manually assigned (#786)	Dana Powers	2016-08-01	1	-0/+1
* \|	Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)	Dana Powers	2016-08-01	3	-6/+6
\|/
*	Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)	Dana Powers	2016-08-01	4	-17/+39
*	Document the ssl_password config option (#780)	Samuel Taylor	2016-07-26	1	-0/+2
*	Merge pull request #772 from dpkp/more_metrics	Dana Powers	2016-07-26	6	-82/+142
\|\
\| *	Add KafkaClient metricsmore_metrics	Dana Powers	2016-07-17	2	-2/+53
\| *	Record produce latency and throttling metrics	Dana Powers	2016-07-17	1	-4/+9
\| *	Add base coordinator metrics	Dana Powers	2016-07-17	3	-76/+80