diff --git a/arangod/Agency/Agent.cpp b/arangod/Agency/Agent.cpp
index 94ca691c30..ac0c3856b4 100644
--- a/arangod/Agency/Agent.cpp
+++ b/arangod/Agency/Agent.cpp
@@ -68,7 +68,7 @@ State const& Agent::state () const {
 
 //  Start all agent thread
 bool Agent::start() {
-  LOG_TOPIC(INFO, Logger::AGENCY) << "Starting agency comm worker.";
+  LOG_TOPIC(DEBUG, Logger::AGENCY) << "Starting agency comm worker.";
   Thread::start();
   return true;
 }
@@ -219,8 +219,8 @@ bool Agent::recvAppendEntriesRPC (term_t term, arangodb::consensus::id_t leaderI
   //    follow it ($5.3)
   // 4. Append any new entries not already in the log
   if (queries->slice().length()) {
-    LOG_TOPIC(INFO, Logger::AGENCY) << "Appending "<< queries->slice().length()
-                                    << " entries to state machine.";
+    LOG_TOPIC(DEBUG, Logger::AGENCY) << "Appending "<< queries->slice().length()
+                                     << " entries to state machine.";
     /* bool success = */
     _state.log (queries, term, leaderId, prevIndex, prevTerm);
   } else { 
@@ -271,7 +271,7 @@ append_entries_t Agent::sendAppendEntriesRPC (arangodb::consensus::id_t follower
 
   // Send request
   if (unconfirmed.size() > 1) {
-    LOG_TOPIC(INFO, Logger::AGENCY)
+    LOG_TOPIC(DEBUG, Logger::AGENCY)
       << "Appending " << unconfirmed.size()-1 << " entries up to index " << last
       << " to follower " << follower_id;
   }
@@ -298,28 +298,28 @@ bool Agent::load() {
     FATAL_ERROR_EXIT();
   }
 
-  LOG_TOPIC(INFO, Logger::AGENCY) << "Loading persistent state.";
+  LOG_TOPIC(DEBUG, Logger::AGENCY) << "Loading persistent state.";
   if (!_state.loadCollections(vocbase, 
                               _config.waitForSync)) {
-    LOG_TOPIC(INFO, Logger::AGENCY)
+    LOG_TOPIC(DEBUG, Logger::AGENCY)
       << "Failed to load persistent state on startup.";
   }
 
-  LOG_TOPIC(INFO, Logger::AGENCY) << "Reassembling spearhead and read stores.";
+  LOG_TOPIC(DEBUG, Logger::AGENCY) << "Reassembling spearhead and read stores.";
   _spearhead.apply(_state.slices(_lastCommitIndex+1));
   reportIn(id(),_state.lastLog().index);
 
-  LOG_TOPIC(INFO, Logger::AGENCY) << "Starting spearhead worker.";
+  LOG_TOPIC(DEBUG, Logger::AGENCY) << "Starting spearhead worker.";
   _spearhead.start(this);
   _readDB.start(this);
 
-  LOG_TOPIC(INFO, Logger::AGENCY) << "Starting constituent personality.";
+  LOG_TOPIC(DEBUG, Logger::AGENCY) << "Starting constituent personality.";
   auto queryRegistry = QueryRegistryFeature::QUERY_REGISTRY;
   TRI_ASSERT(queryRegistry != nullptr);
   _constituent.start(vocbase, queryRegistry);
 
   if (_config.supervision) {
-    LOG_TOPIC(INFO, Logger::AGENCY) << "Starting cluster sanity facilities";
+    LOG_TOPIC(DEBUG, Logger::AGENCY) << "Starting cluster sanity facilities";
     _supervision.start(this);
   }
   
diff --git a/arangod/Agency/Node.cpp b/arangod/Agency/Node.cpp
index 4e9a84ff78..d3f8452b79 100644
--- a/arangod/Agency/Node.cpp
+++ b/arangod/Agency/Node.cpp
@@ -492,7 +492,7 @@ bool Node::applieOp (VPackSlice const& slice) {
   } else if (oper == "unobserve") { // "op":"unobserve"
     return handle<UNOBSERVE>(slice);
   } else {                          // "op" might not be a key word after all
-    LOG_TOPIC(INFO, Logger::AGENCY)
+    LOG_TOPIC(WARN, Logger::AGENCY)
       << "Keyword 'op' without known operation. Handling as regular key.";
   }
   
diff --git a/arangod/Agency/State.cpp b/arangod/Agency/State.cpp
index e0ec58fbe7..b693fc3bf4 100644
--- a/arangod/Agency/State.cpp
+++ b/arangod/Agency/State.cpp
@@ -306,7 +306,7 @@ bool State::loadCollection(std::string const& name) {
     return true;
   } 
   
-  LOG_TOPIC (INFO, Logger::AGENCY) << "Couldn't find persisted log";
+  LOG_TOPIC (DEBUG, Logger::AGENCY) << "Couldn't find persisted log";
   createCollections();
 
   return false;
diff --git a/arangod/Cluster/HeartbeatThread.cpp b/arangod/Cluster/HeartbeatThread.cpp
index 63cb512163..e392ceaa7b 100644
--- a/arangod/Cluster/HeartbeatThread.cpp
+++ b/arangod/Cluster/HeartbeatThread.cpp
@@ -368,7 +368,7 @@ void HeartbeatThread::runCoordinator() {
                 TRI_UseCoordinatorDatabaseServer(_server, i->c_str());
 
             if (vocbase != nullptr) {
-              LOG_TOPIC(INFO, Logger::HEARTBEAT) 
+              LOG_TOPIC(DEBUG, Logger::HEARTBEAT) 
                   << "Reloading users for database " << vocbase->_name
                   << ".";
 
@@ -597,7 +597,7 @@ bool HeartbeatThread::handlePlanChangeCoordinator(uint64_t currentPlanVersion) {
   
   // turn on error logging now
   if (!ClusterComm::instance()->enableConnectionErrorLogging(true)) {
-    LOG_TOPIC(INFO, Logger::HEARTBEAT) 
+    LOG_TOPIC(DEBUG, Logger::HEARTBEAT) 
         << "created coordinator databases for the first time";
   }