Bringing Observability to Your Stream Processing