fix #450: Unreasonable kafka init offset in jobmaker

btccom · Jun 9, 2020 · f312ceb · f312ceb
1 parent 7936ce3
commit f312ceb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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_) {