Rafael Garcia
|
945ed317c2
|
remove logger as parameter
|
2017-11-03 17:48:50 +00:00 |
|
Rafael Garcia
|
221743b3e2
|
write errors to stderr
|
2017-11-02 21:50:46 +00:00 |
|
Xavi Ramirez
|
f581bb4f6e
|
Increased default read rate.
|
2017-08-22 18:37:47 +00:00 |
|
Nathan Leiby
|
5b8a86212d
|
remove DeployEnv (no longer needed)
|
2017-08-10 14:26:27 -07:00 |
|
Xavi Ramirez
|
734b46274f
|
Better coordinated checkpoints and readlines. Checkpoint function now returns all errors.
|
2017-08-07 19:20:56 +00:00 |
|
Xavi Ramirez
|
6a30e0eb8a
|
Huge refactor. Batchers no longer run in their own go-routines, which allowed us to a lot of concurrency and simplify model.
|
2017-08-07 19:20:56 +00:00 |
|
Xavi Ramirez
|
7a7716e824
|
Increased default read rate limit
|
2017-08-07 19:20:56 +00:00 |
|
Xavi Ramirez
|
212ec45d88
|
Added writter unit tests and fixed a slew of concurrency bugs
|
2017-07-21 01:35:54 +00:00 |
|
Xavi Ramirez
|
164b9923be
|
Reworded docs to remove references to firehose. Renamed config variables to be clearer.
|
2017-07-21 01:25:02 +00:00 |
|
Xavi Ramirez
|
906f6b94fc
|
Made ReadBurstLimit relative to read rate limit
|
2017-07-18 19:53:25 +00:00 |
|
Xavi Ramirez
|
8d273d6a1e
|
Fixed and added unit tests
|
2017-07-18 19:19:40 +00:00 |
|
Xavi Ramirez
|
8bcef6cd91
|
Log file closed when kclProcessor is done running
|
2017-07-18 19:12:46 +00:00 |
|
Xavi Ramirez
|
4c67f39c99
|
Implemented new consumer interface as well as example consumer: 'batchconsumer'
|
2017-07-18 02:03:15 +00:00 |
|