DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Sensor | Behavior |
sink-record-read | Registered by both. Counts records polled (same semantics). |
sink-record-send | Registered by both. Counts records delivered to task.put(). |
sink-record-active-count | Registered by both. In Share Groups, this is the number of records currently ACQUIRED but not yet acknowledged. |
put-batch-time | Registered by both. Time spent in task.put(). |
Proposed Changes
At‑Least‑Once (Share Group → SinkTask → External Sink)
Exactly‑Once (Same‑Cluster Kafka‑to‑Kafka, KIP‑1289)
4. Compatibility, Deprecation, and Migration Plan
...