From 21e9fd509b63182657d1b76b02c2921b2a5334b0 Mon Sep 17 00:00:00 2001 From: Bryan Newbold Date: Fri, 15 Nov 2019 15:52:53 -0800 Subject: CI: make some jobs manual Scalding test is broken :( But we aren't even using that code much these days. --- python/sandcrawler/workers.py | 2 ++ 1 file changed, 2 insertions(+) (limited to 'python') diff --git a/python/sandcrawler/workers.py b/python/sandcrawler/workers.py index a23d9a4..25d567f 100644 --- a/python/sandcrawler/workers.py +++ b/python/sandcrawler/workers.py @@ -108,6 +108,8 @@ class KafkaSink(SandcrawlerWorker): config = self.producer_config({ 'bootstrap.servers': kafka_hosts, 'message.max.bytes': 20000000, # ~20 MBytes; broker is ~50 MBytes + 'api.version.request': True, + 'api.version.fallback.ms': 0, }) self.producer = Producer(config) -- cgit v1.2.3