ClickHouse/dbms/tests/integration/test_storage_kafka
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
..
clickhouse_path/format_schemas
configs
__init__.py
kafka_pb2.py
test_kafka_json.reference
test_kafka_virtual1.reference Update references 2019-08-07 12:54:29 +03:00
test_kafka_virtual2.reference Update references 2019-08-07 12:54:29 +03:00
test.py Implement support for insertion into Kafka tables (#6012) 2019-08-20 14:17:57 +03:00