SNOW-0000: extended telemetry with partitionId, fixed the event type sen…

[sfc-gh-gjachimko]

…t on cleaner progress, extended telemetry logging;

Overview

SNOW-0000:

Various telemetry improvements:

• sending kafka_pipe_usage instead of kafka_pipe_start on progress report,
• added partitionId to kafka_pipe_usage (important when troubleshooting issues for topics with many partitions)
• added telemetry logging for failed stage access

Pre-review checklist

• This change should be part of a Behavior Change Release. See go/behavior-change.
• This change has passed Merge gate tests
• Snowpipe Changes
• Snowpipe Streaming Changes
• This change is TEST-ONLY
• This change is README/Javadocs only
• This change is protected by a config parameter <PARAMETER_NAME> eg snowflake.ingestion.method.
  • Yes - Added end to end and Unit Tests.
  • No - Suggest why it is not param protected
• Is his change protected by parameter <PARAMETER_NAME> on the server side?
  • The parameter/feature is not yet active in production (partial rollout or PrPr, see Changes for Unreleased Features and Fixes).
  • If there is an issue, it can be safely mitigated by turning the parameter off. This is also verified by a test (See go/ppp).