From 6dbaedf5a5bf7813a90d4e72dd3812c53fd8b1cf Mon Sep 17 00:00:00 2001
From: wzl12356 <wzlsuccess@163.com>
Date: Sat, 12 Feb 2022 13:05:43 +0800
Subject: [PATCH] kafka: fix offset timestamp overflow bug and BUILD file for
 linux

---
 BUILD                        | 4 +++-
 src/factory/KafkaTaskImpl.cc | 3 ++-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/BUILD b/BUILD
index 51f8bf83..13f747a6 100644
--- a/BUILD
+++ b/BUILD
@@ -1,6 +1,8 @@
 config_setting(
 	name = 'linux',
-	values = {'cpu': 'linux'},
+	constraint_values = [
+		"@platforms//os:linux",
+	],
 	visibility = ['//visibility:public'],
 )
 
diff --git a/src/factory/KafkaTaskImpl.cc b/src/factory/KafkaTaskImpl.cc
index 62c20d41..87d09e67 100644
--- a/src/factory/KafkaTaskImpl.cc
+++ b/src/factory/KafkaTaskImpl.cc
@@ -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
 			{