aboutsummaryrefslogtreecommitdiffstats
path: root/python_hadoop/kafka_grobid_hbase.py
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2019-11-13 16:42:05 -0800
committerBryan Newbold <bnewbold@archive.org>2019-11-13 16:42:07 -0800
commite456e6a17eb9655afc4dc8146f50a7dba4fd8601 (patch)
tree18040877fb6bf72fca6e64438a69d529c0eac2b7 /python_hadoop/kafka_grobid_hbase.py
parent0897e3a5714ff8549e8ab68f44f0c49ce3f0405d (diff)
downloadsandcrawler-e456e6a17eb9655afc4dc8146f50a7dba4fd8601.tar.gz
sandcrawler-e456e6a17eb9655afc4dc8146f50a7dba4fd8601.zip
refactor consume_topic name out of make_kafka_consumer()
Best to do this in wrapping code for full flexibility.
Diffstat (limited to 'python_hadoop/kafka_grobid_hbase.py')
0 files changed, 0 insertions, 0 deletions