From e2be3bbf9cb00b7f7faba60948ef9a0200839218 Mon Sep 17 00:00:00 2001
From: Noah Levitt <nlevitt@archive.org>
Date: Thu, 6 Nov 2014 19:53:41 -0800
Subject: [PATCH] new style kafka configuration properties

---
 .../org/archive/modules/postprocessor/KafkaCrawlLogFeed.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java b/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
index afd84b94..fe20f2f4 100644
--- a/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
+++ b/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
@@ -170,8 +170,8 @@ public class KafkaCrawlLogFeed extends Processor implements Lifecycle {
             synchronized (this) {
                 if (kafkaProducer == null) {
                     Properties props = new Properties();
-                    props.put("metadata.broker.list", getBrokerList());
-                    props.put("request.required.acks", "1");
+                    props.put("bootstrap.servers", getBrokerList());
+                    props.put("acks", "1");
                     props.put("producer.type", "async");
                     kafkaProducer = new KafkaProducer(props);
                 }