Update build failure
@@ -356,7 +356,7 @@ func (e *historyEngineImpl) Start() {
clusterMetadata := e.shard.GetClusterMetadata()
if e.replicatorProcessor != nil &&
- (clusterMetadata.GetReplicationConsumerConfig().Type != sconfig.ReplicationConsumerTypeRPC ||
+ (clusterMetadata.GetReplicationConsumerConfig().Type != config.ReplicationConsumerTypeRPC ||
e.config.EnableKafkaReplication()) {
e.replicatorProcessor.Start()
}
