NewAggregator returns a Aggregator initialized with the kafka details provided.

ErrNoSrc is returned when an Aggregator is created without a kafka source.

Aggregator is an aggregator implementation that reads from the filesystem.

Opts hold configuration for the kafka publisheru.