Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | small fixes to confluent-kafka importers/workers | Bryan Newbold | 2019-09-20 | 1 | -5/+1 |
| | | | | | | | | - decrease default changelog pipeline to 5.0sec - fix missing KafkaException harvester imports - more confluent-kafka tweaks - updates to kafka consumer configs - bump elastic updates consumergroup (again) | ||||
* | convert pipeline workers from pykafka to confluent-kafka | Bryan Newbold | 2019-09-20 | 1 | -29/+48 |
| | |||||
* | refactor all python source for client lib name | Bryan Newbold | 2019-09-05 | 1 | -2/+2 |
| | |||||
* | 10 MByte default Kafka produce (workers) | Bryan Newbold | 2019-03-06 | 1 | -0/+3 |
| | |||||
* | bunch of lint/whitespace cleanups | Bryan Newbold | 2019-02-22 | 1 | -2/+2 |
| | |||||
* | workers do API-passing (not URI-passing) | Bryan Newbold | 2019-01-08 | 1 | -5/+3 |
| | |||||
* | have recent message helper cleanup consumer | Bryan Newbold | 2018-11-15 | 1 | -1/+5 |
| | |||||
* | fix worker code | Bryan Newbold | 2018-11-14 | 1 | -0/+2 |
| | |||||
* | most_recent_message as reusable function | Bryan Newbold | 2018-11-14 | 1 | -0/+25 |
| | |||||
* | shuffle around fatcat_tools layout | Bryan Newbold | 2018-11-13 | 1 | -0/+25 |