ClickHouse/src/Storages/Kafka
2020-11-08 00:17:59 +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 Few more CR fixes 2020-10-12 15:05:40 +02:00
KafkaBlockOutputStream.h Move getSampleBlockNonMaterialized to StorageInMemoryMetadata 2020-06-16 15:48:10 +03:00
KafkaSettings.cpp Better exceptions rethrow 2020-10-26 06:35:57 +03:00
KafkaSettings.h 1. Add new setting for Kafka engine, named kafka_thread_per_consumer which default value is false. 2. Create separate thread pool for Kafka engine. 2020-09-06 11:17:19 +08:00
parseSyslogLevel.cpp Fix half of typos 2020-08-08 03:47:03 +03:00
parseSyslogLevel.h Redirect librdkafka logs from stderr to clickhouse logger 2020-05-17 20:27:36 +03:00
ReadBufferFromKafkaConsumer.cpp Fix half of typos 2020-08-08 03:47:03 +03:00
ReadBufferFromKafkaConsumer.h Try speedup build (#14809) 2020-09-15 12:55:57 +03:00
StorageKafka.cpp Merge branch 'master' into azat-optimize_skip_unused_shards-optimization 2020-11-08 00:17:59 +03:00
StorageKafka.h Merge branch 'master' into azat-optimize_skip_unused_shards-optimization 2020-11-08 00:17:59 +03:00
WriteBufferToKafkaProducer.cpp Fix half of typos 2020-08-08 03:47:03 +03:00
WriteBufferToKafkaProducer.h After CR fixes 2020-10-12 07:52:09 +02:00