new style kafka configuration properties

2026-09-23 14:15:47 +00:00 · 2014-11-06 19:53:41 -08:00
parent d2f70e5c97
commit e2be3bbf9c
1 changed files with 2 additions and 2 deletions
@@ -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);
                }