wbtiger
/
ByConity
mirror of https://github.com/ByConity/ByConity
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
68,352 Commits 116 Branches 33 Tags 417 MiB
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