update dependent

bnb-chain · Sep 19, 2019 · 1dbbe6c · 1dbbe6c
1 parent 902780e
commit 1dbbe6c
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Gopkg.toml b/Gopkg.toml
@@ -42,7 +42,7 @@
 [[constraint]]
   name = "github.com/cosmos/cosmos-sdk"
   source = "github.com/binance-chain/bnc-cosmos-sdk"
-  version = "=v0.25.0-binance.19"
+  branch = "blockhash"
   [[prune.project]]
       name = "github.com/zondax/hid"
       unused-packages = false

diff --git a/app/pub/publisher_kafka.go b/app/pub/publisher_kafka.go
@@ -105,6 +105,16 @@ func (publisher *KafkaMarketDataPublisher) newProducers() (config *sarama.Config
 			return
 		}
 	}
+	if Cfg.PublishBlock{
+		if _, ok := publisher.producers[Cfg.BlockTopic]; !ok {
+			publisher.producers[Cfg.BlockTopic], err =
+				publisher.connectWithRetry(strings.Split(Cfg.BlockKafka, KafkaBrokerSep), config)
+		}
+		if err != nil {
+			Logger.Error("failed to create blocks producer", "err", err)
+			return
+		}
+	}
 	return
 }