Currently, Snowplow apps using this library have no way of knowing....
For Pubsub, when has the Subscriber successfully connected
For Kafka, when have we connected and (more importantly!) when are we in the middle of rebalancing
(We also know nothing about Kinesis health status, but this is more difficult to fix)
We can add a method to SourceAndAck so it reports its health status. In doing so, we can remove the old processingLatency method, so to keep the interface as simple as possible.
Currently, Snowplow apps using this library have no way of knowing....
We can add a method to
SourceAndAckso it reports its health status. In doing so, we can remove the oldprocessingLatencymethod, so to keep the interface as simple as possible.