From 483b453ea2915ea64b8bd566afa35ddf99c3d77e Mon Sep 17 00:00:00 2001
From: wuhao <mikewuhao@163.com>
Date: Tue, 25 Jul 2017 22:58:33 +0800
Subject: [PATCH] skip endOfPeriodMarker in stream method

---
 .../main/java/com/linkedin/databus/core/DbusEventBuffer.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java b/databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java
index 70a61e94..b3195258 100644
--- a/databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java
+++ b/databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java
@@ -2508,6 +2508,10 @@ public StreamEventsResult streamEvents(Checkpoint checkPoint,
         {
           if (skippedMessages < messagesToSkip)
           {
+            if (e.isEndOfPeriodMarker() || e.isCheckpointMessage())
+            {
+              continue;
+            }
             ++skippedMessages;
             continue;
           }