2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-03-03 20:39:17 +00:00

Merge pull request #30 from jjohnson42/replayoldlog

Fix erroneous data injection to log replay
This commit is contained in:
Jarrod Johnson
2015-09-30 13:51:01 -04:00

View File

@@ -633,6 +633,9 @@ class Logger(object):
flock(binfile, LOCK_SH)
binfile.seek(0, 2)
binidx = binfile.tell()
# things have been set up for next iteration to dig to
# previous log file, go to next iteration
continue
elif ltype != 2:
continue
if tstamp > recenttimestamp: