Monitoring metrics

Note: Tsp gather metrics from Flink Monitoring

• numRecordsReadNum - records read from source
• currentEventTs - records handled by patterns
• numRecordsProcessed - records sent to sink (approx.)

Can be configured in application.conf