|
|
@ -15,6 +15,7 @@
|
|
|
|
package main
|
|
|
|
package main
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
|
|
|
|
"errors"
|
|
|
|
"flag"
|
|
|
|
"flag"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"github.com/IBM/sarama"
|
|
|
|
"github.com/IBM/sarama"
|
|
|
@ -125,7 +126,7 @@ func checkMinio() error {
|
|
|
|
|
|
|
|
|
|
|
|
// Check if MinIO is enabled
|
|
|
|
// Check if MinIO is enabled
|
|
|
|
if config.Config.Object.Enable != "minio" {
|
|
|
|
if config.Config.Object.Enable != "minio" {
|
|
|
|
return nil
|
|
|
|
return errs.Wrap(errors.New("minio.Enable is empty"))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
minio := &component.Minio{
|
|
|
|
minio := &component.Minio{
|
|
|
|
ApiURL: config.Config.Object.ApiURL,
|
|
|
|
ApiURL: config.Config.Object.ApiURL,
|
|
|
|