From 23fa29d673c90ed14940c6a059e478ed22a1eb11 Mon Sep 17 00:00:00 2001
From: Noah Levitt <nlevitt@archive.org>
Date: Wed, 5 Nov 2014 14:03:54 -0800
Subject: [PATCH] fix log messages to say "kafka"

---
 .../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 bc65b200..c1fd8ffc 100644
--- a/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
+++ b/contrib/src/main/java/org/archive/modules/postprocessor/KafkaCrawlLogFeed.java
@@ -148,9 +148,9 @@ public class KafkaCrawlLogFeed extends Processor implements Lifecycle {
                     }
                 };
 
-                logger.info("dumping " + frontier.queuedUriCount() + " queued urls to amqp feed");
+                logger.info("dumping " + frontier.queuedUriCount() + " queued urls to kafka feed");
                 ((BdbFrontier) frontier).forAllPendingDo(closure);
-                logger.info("dumped " + pendingDumpedCount + " queued urls to amqp feed");
+                logger.info("dumped " + pendingDumpedCount + " queued urls to kafka feed");
             } else {
                 logger.warning("frontier is not a BdbFrontier, cannot dumpPendingAtClose");
             }