diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2019-11-13 17:09:44 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2019-11-13 17:09:46 -0800 |
| commit | 0b62cec8ee674793d890ab4cc5730933b5278b2f (patch) | |
| tree | 39da35a25e8d6daf5766e26c904d5e713507c370 | |
| parent | 47e0b699b2a350b0081a64ebbcaba991c53cfb52 (diff) | |
| download | sandcrawler-0b62cec8ee674793d890ab4cc5730933b5278b2f.tar.gz sandcrawler-0b62cec8ee674793d890ab4cc5730933b5278b2f.zip | |
new kafka topics for file ingest
Created these for 'qa' and 'prod'
| -rw-r--r-- | kafka/topics.md | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/kafka/topics.md b/kafka/topics.md index 36337da..614e9a3 100644 --- a/kafka/topics.md +++ b/kafka/topics.md @@ -25,6 +25,18 @@ retention (on both a size and time basis). => fewer partitions with batch mode, but still a bunch (24?) => key is sha1hex of PDF. enable time compaction (6 months?) + sandcrawler-ENV.ingest-file-requests + => ingest requests from multiple sources + => schema is JSON; see ingest proposal for fields. small objects. + => fewer partitions with batch mode, but still a bunch (24) + => can't think of a good key, so none. enable time compaction (3-6 months?) + + sandcrawler-ENV.ingest-file-results + => ingest requests from multiple sources + => schema is JSON; see ingest proposal for fields. small objects. + => 6 partitions + => can't think of a good key, so none; no compaction + fatcat-ENV.api-crossref fatcat-ENV.api-datacite => all new and updated DOIs (regardless of type) @@ -99,6 +111,9 @@ exists`; this seems safe, and the settings won't be over-ridden. ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 24 --topic sandcrawler-qa.ungrobided-pg ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 12 --topic sandcrawler-qa.grobid-output-pg --config compression.type=gzip --config cleanup.policy=compact + ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 24 --topic sandcrawler-qa.ingest-file-requests --config retention.ms=7889400000 --config cleanup.policy=delete + ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 6 --topic sandcrawler-qa.ingest-file-results + ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic fatcat-qa.changelog ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 8 --topic fatcat-qa.release-updates-v03 ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 8 --topic fatcat-qa.work-updates |