14 Commits

Author	SHA1	Message	Date
Ivan Lezhankin	0917573493	Merge remote-tracking branch 'upstream/master' into issue-5286	2019-06-24 14:42:58 +03:00
Ivan Lezhankin	b75db2ef04	Fix dropping message to early when stalling	2019-06-21 17:29:10 +03:00
Ivan Lezhankin	61750d09d2	Commit offsets for SELECTing from Kafka table too	2019-06-20 15:34:25 +03:00
Ivan Lezhankin	fdd3f07860	Don't do premature subscription to topics	2019-06-19 19:15:30 +03:00
Ivan Lezhankin	d907d8e8ca	Commit offsets for SELECTing from Kafka table too	2019-06-17 19:27:18 +03:00
Ivan Lezhankin	8326021d74	Fix style	2019-06-03 17:36:59 +03:00
Ivan Lezhankin	13212c9b01	Fix the hang on dropping Kafka table when there is no mat. views	2019-05-27 20:25:34 +03:00
Ivan Lezhankin	a14013dff7	Add setting to regulate Kafka committing policy.	2019-05-16 18:20:30 +03:00
Ivan	1ea9e3019d	Freeze the Kafka buffer after first empty response (#5283) ... * Check inside inferior streams for cancellation while reading. * Stop reading from Kafka buffer after first empty read.	2019-05-15 19:11:50 +03:00
Ivan	4a5832b18a	Check the time limit every (flush_interval / poll_timeout) number of rows from Kafka (#5249)	2019-05-14 18:52:03 +03:00
Ivan Lezhankin	94bba1918f	Do not drop Kafka consumer buffers after closing stream	2019-04-22 16:23:05 +03:00
Ivan Lezhankin	681266abd0	Poll messages in batches of max_block_size size.	2019-01-25 15:48:59 +03:00
Ivan Lezhankin	862d419f31	Fix losing the next message after a broken one.	2019-01-24 14:58:25 +03:00
Ivan Lezhankin	c8e605327d	Split StorageKafka.cpp on smaller files per class	2019-01-24 14:58:24 +03:00