diff --git a/consensus/log.go b/consensus/log.go
index 0514a66d3..26f7b858d 100644
--- a/consensus/log.go
+++ b/consensus/log.go
@@ -4,4 +4,13 @@ import (
 	"github.com/tendermint/go-logger"
 )
 
-var log = logger.New("module", "consensus")
+var log = logger.NewBypass("module", "consensus")
+
+func init() {
+	log.SetHandler(
+		logger.LvlFilterHandler(
+			logger.LvlDebug,
+			logger.BypassHandler(),
+		),
+	)
+}
diff --git a/consensus/state.go b/consensus/state.go
index 867f019d0..5ebac0798 100644
--- a/consensus/state.go
+++ b/consensus/state.go
@@ -154,7 +154,7 @@ func (rs *RoundState) StringShort() string {
 type ConsensusState struct {
 	BaseService
 
-	proxyAppCtx      proxy.AppContext
+	proxyAppCtx   proxy.AppContext
 	blockStore    *bc.BlockStore
 	mempool       *mempl.Mempool
 	privValidator *types.PrivValidator
@@ -172,10 +172,10 @@ type ConsensusState struct {
 
 func NewConsensusState(state *sm.State, proxyAppCtx proxy.AppContext, blockStore *bc.BlockStore, mempool *mempl.Mempool) *ConsensusState {
 	cs := &ConsensusState{
-		proxyAppCtx:   proxyAppCtx,
-		blockStore: blockStore,
-		mempool:    mempool,
-		newStepCh:  make(chan *RoundState, 10),
+		proxyAppCtx: proxyAppCtx,
+		blockStore:  blockStore,
+		mempool:     mempool,
+		newStepCh:   make(chan *RoundState, 10),
 	}
 	cs.updateToState(state)
 	// Don't call scheduleRound0 yet.
@@ -532,8 +532,10 @@ func (cs *ConsensusState) EnterPrevote(height int, round int, timedOut bool) {
 
 	// fire event for how we got here
 	if timedOut {
+		log.Debug("Propose timed out")
 		cs.evsw.FireEvent(types.EventStringTimeoutPropose(), cs.RoundStateEvent())
 	} else if cs.isProposalComplete() {
+		log.Debug("Propose is complete")
 		cs.evsw.FireEvent(types.EventStringCompleteProposal(), cs.RoundStateEvent())
 	} else {
 		// we received +2/3 prevotes for a future round
diff --git a/mempool/reactor.go b/mempool/reactor.go
index ed8b8b260..d6140d2d4 100644
--- a/mempool/reactor.go
+++ b/mempool/reactor.go
@@ -63,7 +63,7 @@ func (memR *MempoolReactor) Receive(chID byte, src *p2p.Peer, msgBytes []byte) {
 		log.Warn("Error decoding message", "error", err)
 		return
 	}
-	log.Notice("MempoolReactor received message", "msg", msg)
+	log.Info("MempoolReactor received message", "msg", msg)
 
 	switch msg := msg.(type) {
 	case *TxMessage: