packagemainimport("fmt""time")funcbatchProcessor(ch<-chanstring,batchSizeint,flushIntervaltime.Duration){varbatch[]stringtimer:=time.NewTimer(flushInterval)for{