diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2020-01-28 18:55:36 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2020-01-28 18:55:39 -0800 |
| commit | 08377ca3fdb7103ce0e0a98f7ae9e2baa39febf8 (patch) | |
| tree | 7518d73712d36bda2e4c7fda9a3afe923e9c91de /python_hadoop/kafka_grobid_hbase.py | |
| parent | e0c2cc4b1a41b5de40c9e3adc9cba36d4dc93ed1 (diff) | |
| download | sandcrawler-08377ca3fdb7103ce0e0a98f7ae9e2baa39febf8.tar.gz sandcrawler-08377ca3fdb7103ce0e0a98f7ae9e2baa39febf8.zip | |
grobid worker: always set a key in response
We have key-based compaction enabled for the GROBID output topic. This
means it is an error to public to that topic without a key set.
Hopefully this change will end these errors, which look like:
KafkaError{code=INVALID_MSG,val=2,str="Broker: Invalid message"}
Diffstat (limited to 'python_hadoop/kafka_grobid_hbase.py')
0 files changed, 0 insertions, 0 deletions