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

	Commit message (Expand)	Author	Age	Files	Lines
*	Use socket_options configuration to setsockopts(). Default TCP_NODELAYsocket_options	Dana Powers	2016-07-30	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
* \|	change pickle_method to use python3 special attributes (#777)	John Win	2016-07-26	1	-3/+9
* \|	Fix typo in KafkaConsumer documentation (#775)	Samuel Taylor	2016-07-21	1	-1/+1
\|/
*	Fix ProduceResponse v2 throttle_time_ms	Dana Powers	2016-07-17	1	-1/+1
*	Always encode size with MessageSet (#771)	Dana Powers	2016-07-17	2	-5/+3
*	Catch select errors while capturing test fixture logs	Dana Powers	2016-07-17	1	-1/+7
*	Avoid buffer overread when compressing messageset in KafkaProducer	Dana Powers	2016-07-17	1	-1/+2
*	Expand consumer.fetcher comment re comparing request / response offsets	Dana Powers	2016-07-17	1	-1/+3
*	Delete KafkaConnection class (#769)	Dana Powers	2016-07-17	3	-398/+2
*	KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770...	Dana Powers	2016-07-17	5	-19/+38
*	Explicit format string argument indices for python 2.6 compatibility	Dana Powers	2016-07-17	3	-4/+4
*	Simplify RecordMetadata; short circuit callbacks (#768)	Dana Powers	2016-07-17	2	-20/+9
*	KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)	Dana Powers	2016-07-17	2	-49/+8
*	KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)	Dana Powers	2016-07-17	2	-11/+25
*	KAFKA-2832: Add a consumer config option to exclude internal topics (#765)	Dana Powers	2016-07-17	2	-4/+13
*	Expose selector type as config option (#764)	Dana Powers	2016-07-16	3	-3/+15
*	Protect writes to wakeup socket with threading lock (#763 / #709)	Dana Powers	2016-07-16	1	-2/+6
*	Merge pull request #762 from dpkp/metadata_v1	Dana Powers	2016-07-16	8	-52/+154
\|\
\| *	Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1	Dana Powers	2016-07-16	2	-9/+51
\| *	Add rack to BrokerMetadata - it is always None when using MetadataRequest v0	Dana Powers	2016-07-16	5	-40/+52
\| *	Add protocol structs for Metadata v1	Dana Powers	2016-07-16	1	-4/+36
\| *	Add protocol support for null Arrays	Dana Powers	2016-07-16	1	-0/+6
\| *	Add Boolean protocol type	Dana Powers	2016-07-16	1	-0/+10
* \|	Update kafka configuration links -> 0.10.0.0 docs	Dana Powers	2016-07-16	2	-2/+2
* \|	Merge pull request #754 from dpkp/benchmarks	Dana Powers	2016-07-16	11	-27/+640
\|\ \
\| * \|	Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jythonbenchmarks	Dana Powers	2016-07-16	2	-0/+337
\| * \|	Move load_example.py to benchmarks/	Dana Powers	2016-07-16	1	-0/+0
\| * \|	Update Sensor time_ms docs; only calculate if needed	Dana Powers	2016-07-16	1	-3/+3
\| * \|	First stab at public metrics() interface for KafkaConsumer / KafkaProducer	Dana Powers	2016-07-16	2	-2/+31
\| * \|	Add comment re fetcher stats on compressed topics	Dana Powers	2016-07-16	1	-0/+2
\| * \|	Fixup metrics_sample_window_ms docstring in consumer	Dana Powers	2016-07-16	1	-2/+2
\| * \|	KAFKA-3785: Fetcher spending unnecessary time during metrics recording	Dana Powers	2016-07-16	1	-2/+4
\| * \|	Add initial producer-sender metrics	Dana Powers	2016-07-16	5	-18/+261
\| \|/
* \|	#761 Follow-up: use api_version tuples in BrokerConnection.check_version	Dana Powers	2016-07-16	1	-11/+10
\|/
*	Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)	Dana Powers	2016-07-16	9	-140/+146
*	Include zk-offset configuration in coordinator unit tests	Dana Powers	2016-07-16	1	-2/+6
*	Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)	Dana Powers	2016-07-16	3	-23/+27
*	Cleanup error logging (#760 / #759)	Dana Powers	2016-07-15	2	-2/+12
*	Bump version for development	Dana Powers	2016-07-15	1	-1/+1
*	Patch Release 1.2.51.2.5	Dana Powers	2016-07-15	3	-1/+19
*	Merge pull request #755 from dpkp/unrecurse_unpack_message_set	Dana Powers	2016-07-15	2	-17/+64
\|\
\| *	Add skip_double_compressed_messages option to KafkaConsumerunrecurse_unpack_message_set	Dana Powers	2016-07-14	2	-0/+20
\| *	Log warning if message set appears double-compressed in KafkaConsumer	Dana Powers	2016-07-14	1	-0/+8
\| *	Drop recursion in _unpack_message_set	Dana Powers	2016-07-14	1	-17/+36
\|/
*	Merge pull request #757 from dpkp/double_compression	Dana Powers	2016-07-14	2	-16/+93
\|\