Merge pull request #81 from buptyzc/fixTooManyEndPeriodMarker

Fix too many end period marker

Author: chavdar

databus-core/databus-core-impl/src/main/java/com/linkedin/databus/core/DbusEventBuffer.java

@@ -3331,6 +3331,7 @@ private int readEventsInternal(ReadableByteChannel readChannel,
 
               readBuffer.flip();
               boolean hasMoreInStgBuffer = true;
+              boolean preEndPeriodEvent = false;
               while (hasMoreInStgBuffer && readPos.hasNext())
               {
                 writePos.startNewIteration();
@@ -3347,6 +3348,22 @@ private int readEventsInternal(ReadableByteChannel readChannel,
                 {
                 case OK:
                 {
+                  if (readPos.getCurEvent().isEndOfPeriodMarker())
+                  {
+                    if (preEndPeriodEvent)
+                    {
+                      readPos.eventSkipped();
+                      break;
+                    }
+                    else
+                    {
+                      preEndPeriodEvent = true;
+                    }
+                  }
+                  else
+                  {
+                    preEndPeriodEvent = false;
+                  }
                   final int curEventSize = readPos.getCurEvent().size();
                   if (readPos.bytesProcessed() + curEventSize > contiguousCapacity)
                   {