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);
                 }