From f312ceb304caeae40cb94b6932b5216375e748bd Mon Sep 17 00:00:00 2001
From: SwimmingTiger <hu60.cn@gmail.com>
Date: Tue, 9 Jun 2020 09:52:51 +0800
Subject: [PATCH] fix #450: Unreasonable kafka init offset in jobmaker

---
 src/bitcoin/JobMakerBitcoin.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/bitcoin/JobMakerBitcoin.cc b/src/bitcoin/JobMakerBitcoin.cc
index 3cbf89b90..7b2a268df 100644
--- a/src/bitcoin/JobMakerBitcoin.cc
+++ b/src/bitcoin/JobMakerBitcoin.cc
@@ -102,7 +102,7 @@ bool JobMakerHandlerBitcoin::initConsumerHandlers(
   auto kafkaConsumer =
       std::make_shared<KafkaQueueConsumer>(kafkaBrokers, topics);
   std::map<string, string> options{{"fetch.wait.max.ms", "5"}};
-  kafkaConsumer->setup(1, &options);
+  kafkaConsumer->setup(RD_KAFKA_OFFSET_TAIL(1), &options);
   JobMakerConsumerHandler handler{
       kafkaConsumer, [this](const std::string &msg, const std::string &topic) {
         if (topic == def()->rawGbtTopic_) {