ClickHouse/utils/kafka
Ivan a502424c33
Implement support for insertion into Kafka tables ()
* 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
..
consume.py Implement support for insertion into Kafka tables () 2019-08-20 14:17:57 +03:00
manage.py Add helper utils to interact with Kafka broker 2019-04-18 17:36:51 +03:00
produce.py Check the time limit every (flush_interval / poll_timeout) number of rows from Kafka () 2019-05-14 18:52:03 +03:00
status.py Add helper utils to interact with Kafka broker 2019-04-18 17:36:51 +03:00