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

	Commit message (Expand)	Author	Age	Files	Lines
*	Add `log_start_offset` to message protocol parsing (#2020)	Tincu Gabriel	2020-03-25	1	-4/+4
*	Remove unused import	Jeff Widman	2019-01-28	1	-1/+0
*	Be explicit with tuples for %s formatting	Jeff Widman	2018-11-18	1	-3/+3
*	raising logging level on messages signalling data loss (#1553)	Alexander Sibiryakov	2018-11-10	1	-2/+3
*	Support produce with Kafka record headers	Heikki Nousiainen	2018-09-27	1	-7/+9
*	Don't use `kafka.common` internally1.3.5	Jeff Widman	2018-06-05	1	-2/+2
*	use absolute imports everywhere (#1362)	Kevin Tindall	2018-02-06	1	-4/+4
*	Fix timestamp not passed to RecordMetadata (#1273)	Taras Voinarovskyi	2017-10-22	1	-6/+5
*	Added minor fixes for PR review	Taras	2017-10-12	1	-15/+3
*	Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...	Taras	2017-10-11	1	-45/+55
*	Fix batch expiry messages to state seconds	Dominic Evans	2017-07-26	1	-3/+3
*	raise KafkaTimeoutException when flush times out	Andrew Kowalik	2017-06-16	1	-2/+5
*	Improve error message when expiring batches in KafkaProducer (#1077)	Dana Powers	2017-05-03	1	-7/+11
*	Fixup doc references to max_in_flight_requests_per_connection	Dana Powers	2016-12-17	1	-1/+1
*	:wPass timestamp into Message, not just mimic it (#875)	Taras Voinarovskyi	2016-11-18	1	-2/+6
*	Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics	Dana Powers	2016-08-04	1	-1/+5
*	Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)	Dana Powers	2016-08-01	1	-2/+2
*	KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord (#770...	Dana Powers	2016-07-17	1	-1/+4
*	Add initial producer-sender metrics	Dana Powers	2016-07-16	1	-3/+3
*	KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699)	Dana Powers	2016-05-22	1	-7/+39
*	KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarant...	Dana Powers	2016-05-22	1	-11/+20
*	Dont use soon-to-be-reserved keyword await as function name (FutureProduceRes...	Dana Powers	2016-05-22	1	-1/+1
*	KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...	Dana Powers	2016-05-22	1	-13/+19
*	Remove unused importskafka-3318	Dana Powers	2016-04-05	1	-4/+1
*	KAFKA-3013: Include topic-partition in exception for expired batches	Dana Powers	2016-04-05	1	-1/+4
*	Update imports from kafka.common -> kafka.errors / kafka.structs	Dana Powers	2016-04-05	1	-2/+2
*	Fix producer threading bug that could crash sender (dict changing during iter...accumulator_bugfix	Dana Powers	2016-03-14	1	-2/+4
*	Add optional timeout parameter to KafkaProducer.flush()	Dana Powers	2016-03-13	1	-7/+11
*	Catch duplicate batch.done() calls -- this can happen if we maybe_expire then...	Dana Powers	2016-02-18	1	-1/+4
*	Warn if pending batches failed during flush	Dana Powers	2016-02-18	1	-0/+3
*	Fix concurrency bug in RecordAccumulator.ready()	Dana Powers	2016-02-18	1	-2/+6
*	Support batch_size = 0 in producer buffersbatch_size_zero	Dana Powers	2016-02-17	1	-1/+1
*	Fix accumulator bug: expired batches should be removed from the internal queue	Dana Powers	2016-02-02	1	-0/+10
*	Add support for LZ4 compressed messages using python-lz4 module	Dana Powers	2016-01-25	1	-1/+1
*	RecordAccumulator and RecordBatch, for use by async batching KafkaProducer	Dana Powers	2016-01-24	1	-0/+500