breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka: fix offset timestamp overflow bug and BUILD file for linux

Browse Source
This commit is contained in:
wzl12356
2022-02-12 13:05:43 +08:00
parent 18bbbfe616
commit 6dbaedf5a5
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
BUILD
View File

@@ -1,6 +1,8 @@
config_setting(
name = 'linux',
values = {'cpu': 'linux'},
constraint_values = [
"@platforms//os:linux",
],
visibility = ['//visibility:public'],
)

3
src/factory/KafkaTaskImpl.cc
View File

@@ -236,8 +236,9 @@ CommMessageOut *__ComplexKafkaTask::message_out()
}
else
{
toppar->set_offset(toppar->get_high_watermark());
toppar->set_offset(toppar->get_high_watermark() - 1);
}
continue;
}
else
{