Commit Graph

9 Commits

Author SHA1 Message Date
Azat Khuzhin
9cb3c743bd
Convert to python3 (#15007) 2020-10-02 19:54:07 +03:00
Ivan Blinkov
6ae6707eda
Update status.py 2019-11-01 19:14:58 +03:00
Ivan Blinkov
d0c65b491a
Update status.py 2019-11-01 19:10:50 +03:00
Ivan Blinkov
659b467290
Update produce.py 2019-11-01 19:10:15 +03:00
Ivan Blinkov
ac7fb00849
Update manage.py 2019-11-01 19:09:35 +03:00
Ivan Blinkov
4765b7bee5
[utils/kafka] provide some exit code from main 2019-11-01 19:08:29 +03:00
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
Ivan
4a5832b18a
Check the time limit every (flush_interval / poll_timeout) number of rows from Kafka (#5249) 2019-05-14 18:52:03 +03:00
Ivan Lezhankin
7723a63d0a Add helper utils to interact with Kafka broker 2019-04-18 17:36:51 +03:00