ClickHouse/src/Storages/Kafka
2020-08-06 17:32:50 +03:00
..
Buffer_fwd.h dbms/ → src/ 2020-04-03 18:14:31 +03:00
KafkaBlockInputStream.cpp kafka: avoid superior polling after DROP/DETACH TABLE 2020-07-03 09:23:39 +03:00
KafkaBlockInputStream.h Fix SIGSEGV in StorageKafka when broker is unavailable 2020-07-22 11:28:07 +03:00
KafkaBlockOutputStream.cpp Move getSampleBlockNonMaterialized to StorageInMemoryMetadata 2020-06-16 15:48:10 +03:00
KafkaBlockOutputStream.h Move getSampleBlockNonMaterialized to StorageInMemoryMetadata 2020-06-16 15:48:10 +03:00
KafkaSettings.cpp Rework and rename the template class SettingsCollection => BaseSettings. 2020-07-31 20:54:18 +03:00
KafkaSettings.h Rework and rename the template class SettingsCollection => BaseSettings. 2020-07-31 20:54:18 +03:00
parseSyslogLevel.cpp Progress on task 2020-05-24 00:50:34 +03:00
parseSyslogLevel.h Redirect librdkafka logs from stderr to clickhouse logger 2020-05-17 20:27:36 +03:00
ReadBufferFromKafkaConsumer.cpp Fix some bad tests 2020-07-30 22:59:49 +03:00
ReadBufferFromKafkaConsumer.h kafka: fix SIGSEGV if there is an message with error in the middle of the batch 2020-07-10 11:41:44 +03:00
StorageKafka.cpp Merge branch 'master' into refactor-pipes-3 2020-08-06 17:32:50 +03:00
StorageKafka.h Merge branch 'master' into refactor-pipes-3 2020-08-04 11:32:34 +03:00
WriteBufferToKafkaProducer.cpp dbms/ → src/ 2020-04-03 18:14:31 +03:00
WriteBufferToKafkaProducer.h dbms/ → src/ 2020-04-03 18:14:31 +03:00