Stop and reset ticker after processing

This is required so that batches are made of big size at the time of full sink.
Solves Time part of #172 (comment)

pkg/redshiftloader/loader_handler.go

@@ -162,6 +162,7 @@ func (h *loaderHandler) ConsumeClaim(session sarama.ConsumerGroupSession,
 			)
 			return fmt.Errorf("session ctx done, err: %v", session.Context().Err())
 		case message, ok := <-claimMsgChan:
+			maxWaitTicker.Stop()
 			if !ok {
 				klog.V(2).Infof(
 					"%s: consumeClaim returning. read msg channel closed",
@@ -220,6 +221,7 @@ func (h *loaderHandler) ConsumeClaim(session sarama.ConsumerGroupSession,
 				return err
 			}
 			*lastSchemaId = upstreamJobSchemaId
+			maxWaitTicker.Reset(time.Duration(*h.maxWaitSeconds) * time.Second)
 		case <-maxWaitTicker.C:
 			// Process the batch by time
 			klog.V(2).Infof(