SneaksAndData / arcane-framework

Akka.NET-based framework for data streaming services using the Arcane Kubernetes Operator
Apache License 2.0
5 stars 2 forks source link

[FEATURE] More observability for stream sources #91

Open s-vitaliy opened 3 months ago

s-vitaliy commented 3 months ago

Description

Recently, we encountered a problem where the SQL streaming source was executing schema update queries on the target SQL table at a frequency equivalent to the change capture interval. Ideally, the stream should only initiate these updates when a schema change is detected. It's important to note, however, that we currently have no evidence linking this issue directly to the change capture interval. Therefore, to gain a better understanding of the issue, we need to improve the observability of our streaming sources.

Possible solution

Add additional metrics describing the following events:

Alternatives

Add logging for those events.

Context

Required for all stream sources in the framework that supports schema change detection (SQL and CDM for now).