fatcat/python, branch confluent-kafka
[no description]
https://git.bnewbold.net/fatcat/atom?h=confluent-kafka
2019-04-09T04:51:36+00:00
fix missing KafkaException harvester imports
2019-04-09T04:51:36+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-09T04:51:36+00:00
urn:sha1:95943072da4afd1611b790d9900048100545a803
decrease default changelog pipeline to 5.0sec
2019-04-09T04:12:36+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-09T04:12:36+00:00
urn:sha1:f787d92c7463385a08cb56fd9ec1d66d1f4bfce9
convert pipeline workers from pykafka to confluent-kafka
2019-04-09T04:11:25+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-09T04:11:25+00:00
urn:sha1:49c754e10e55376881038d306d70ac7623fe3d90
small kafka tweaks for robustness
2019-04-09T04:10:45+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-09T04:10:45+00:00
urn:sha1:aac6727d2fdf59e09c1f42da19a9a894304acc00
convert importers to confluent-kafka library
2019-04-08T22:47:50+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-08T22:42:55+00:00
urn:sha1:c6db48b47ac53d9ca05d2ce33f97fb73fb85131d
bump max message size to ~20 MBytes
2019-04-08T22:04:50+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-08T22:04:50+00:00
urn:sha1:d43ee5f73e1f7d7f6317d1e7dfb1ddd0e510a353
fixes to confluent-kafka harvesters
2019-04-08T21:58:20+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-08T21:58:20+00:00
urn:sha1:953886e6e42294ca81583e9b2c4e2fa16343a86e
first draft harvesters using confluent-kafka
2019-04-07T04:15:48+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-07T04:15:48+00:00
urn:sha1:8656ddf280aee3af459c3066679c534616fdca93
make default kafka env 'dev', not 'qa'
2019-04-07T04:15:18+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-07T04:15:18+00:00
urn:sha1:a0d32fc3e971e211e6fd7d484dfa247da77e2a8d
add confluent-kafka library (to replace pykafka)
2019-04-07T04:05:55+00:00
Bryan Newbold
bnewbold@robocracy.org
2019-04-07T04:05:55+00:00
urn:sha1:05886f895c93bf39173cf1cc16aeabd37358ccb7