diff --git a/cli/kafka/runner.go b/cli/kafka/runner.go index 125735957..cacde76bb 100644 --- a/cli/kafka/runner.go +++ b/cli/kafka/runner.go @@ -30,7 +30,7 @@ func NewRunner(cfg ConfigForIDK, batcher fbbatch.Batcher, logWriter io.Writer) * idkMain.Batcher = batcher idkMain.BatchSize = cfg.BatchSize idkMain.BatchMaxStaleness = cfg.BatchMaxStaleness - idkMain.Basic() + idkMain.SetBasic() idkMain.SetLog(logger.NewStandardLogger(logWriter)) kr := &Runner{ diff --git a/idk/ingest.go b/idk/ingest.go index 67e495de6..e5b01dda4 100644 --- a/idk/ingest.go +++ b/idk/ingest.go @@ -245,9 +245,10 @@ func (m *Main) Rename() { } } -// Basic sets up Main with basic functionality, excluding those things which are -// not required for some implementations (such as the kafka runner in fbsql). -func (m *Main) Basic() { +// SetBasic sets up Main with basic functionality, excluding those things which +// are not required for some implementations (such as the kafka runner in +// fbsql). +func (m *Main) SetBasic() { m.basic = true }