14 Commits

Author	SHA1	Message	Date
Ivan	05b17976d1	Commit to Kafka explicitly after the writing is finalized (#7175)	2019-10-03 00:17:19 +03:00
Alexey Milovidov	a1101e5278	Fixed build	2019-08-28 16:21:19 +03:00
Ivan	a502424c33	Implement support for insertion into Kafka tables (#6012) ... * Add write-callback on each row for RowOutputStream * Fix build of new rdkafka library * Poll messages if Kafka outgoing queue is full * Add test * Add test producer-consumer * Truncate delimiter from last row in message	2019-08-20 14:17:57 +03:00
Ivan Lezhankin	436052c67b	Merge branch 'master' into issue-5286	2019-06-18 16:03:29 +03:00
Alexey Milovidov	8b87511e25	Namespace comments are unneeded according to the code style. ... find dbms -name '*.h' -or -name '*.cpp' | xargs grep -l -P '}\s*//+\s*namespace\s*' | xargs sed -i -r -e 's/}\s*\/\/+\s*namespace\s*\w+/}/'	2019-06-13 13:37:13 +03:00
Ivan Lezhankin	800854119e	Add buffer callback to fill in virtual columns	2019-05-23 14:15:18 +03:00
Ivan Lezhankin	dd906eabdc	[WIP] refactoring	2019-05-22 22:38:43 +03:00
Ivan Lezhankin	94bba1918f	Do not drop Kafka consumer buffers after closing stream	2019-04-22 16:23:05 +03:00
Ivan Lezhankin	15ad409875	Tests are now passing locally	2019-02-11 14:54:30 +03:00
Ivan Lezhankin	39e2563f93	Create new consumers on-demand ... and give them some time for graceful assignment.	2019-01-30 20:58:49 +03:00
Ivan Lezhankin	681266abd0	Poll messages in batches of max_block_size size.	2019-01-25 15:48:59 +03:00
Ivan Lezhankin	9636bdcd67	Fix build	2019-01-24 15:44:58 +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