ClickHouse/dbms/src/Storages/Kafka
2020-02-05 08:05:55 +01:00
..
Buffer_fwd.h Don't push to MVs when inserting into Kafka table (#7265) 2019-10-22 13:31:28 +03:00
KafkaBlockInputStream.cpp Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
KafkaBlockInputStream.h Test for flushing by time and by block size (+fix), one extra test for virual columns 2020-01-28 14:24:37 +01:00
KafkaBlockOutputStream.cpp draft implementation, wip 2020-02-03 11:02:52 +01:00
KafkaBlockOutputStream.h Implement support for insertion into Kafka tables (#6012) 2019-08-20 14:17:57 +03:00
KafkaSettings.cpp Do not include Field.h everywhere through SettingsCommon.h. 2019-10-07 20:23:05 +03:00
KafkaSettings.h Add the ignorable flag for the settings. 2019-11-17 03:56:18 +03:00
ReadBufferFromKafkaConsumer.cpp Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
ReadBufferFromKafkaConsumer.h Kafka proper rebalances processing, controlled assignment, faster tests 2020-01-30 20:30:45 +01:00
StorageKafka.cpp After review fixes 2020-02-04 22:19:34 +01:00
StorageKafka.h After review fixes 2020-02-04 22:19:34 +01:00
WriteBufferToKafkaProducer.cpp Fixing test build, more review fixes 2020-02-05 08:05:55 +01:00
WriteBufferToKafkaProducer.h After review fixes 2020-02-04 22:19:34 +01:00