GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-29 11:36:47 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #805 from wzl12356/windows

Browse Source 
kafka: filter smaller offset when fetch api (Windows)
This commit is contained in:
xiehan
2022-03-16 14:53:06 +08:00
committed by GitHub
parent 3c2394d096 075b794e45
commit f1435ac835
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/protocol/KafkaMessage.cc
+2 -2
View File
@@ -49,7 +49,7 @@ typedef SSIZE_T ssize_t;
namespace {
#define CLOCK_REALTIME 0
#define CLOCK_REALTIME 0
#define exp7 10000000i64 //1E+7 //C-file part
#define exp9 1000000000i64 //1E+9
#define w2ux 116444736000000000i64 //1.jan1601 to 1.jan1970
@@ -1422,7 +1422,7 @@ int KafkaMessage::parse_message_record(void **buf, size_t *size,
list_add_tail(&header->list, &record->header_list);
}
return 0;
return record->offset < record->toppar->offset ? 1 : 0;;
}
int KafkaMessage::parse_record_batch(void **buf, size_t *size,