mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-10-06 19:07:50 +00:00
32 lines
606 B
Go
32 lines
606 B
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
|
|
"github.com/jaffee/commandeer/pflag"
|
|
"github.com/featurebasedb/featurebase/v3/idk/kafka"
|
|
)
|
|
|
|
func main() {
|
|
dm, err := kafka.NewMain()
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
dm.Delete = true
|
|
|
|
if err := pflag.LoadEnv(dm, "CONSUMER_DEL_", nil); err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
dm.Rename()
|
|
if dm.DryRun {
|
|
log.Printf("%+v\n", dm)
|
|
return
|
|
}
|
|
if err := dm.Run(); err != nil {
|
|
logger := dm.Log()
|
|
if logger != nil {
|
|
logger.Printf("Error running command: %v", err)
|
|
}
|
|
log.Fatal(err) // make sure we log to stderr if the error happened before logging was set up
|
|
}
|
|
}
|