This repository has been archived by the owner on Jun 7, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 293
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adding schemas for the remaining KPI events
- Loading branch information
Thomas Abraham
committed
Mar 31, 2022
1 parent
d95baf9
commit bdd36c4
Showing
3 changed files
with
93 additions
and
0 deletions.
There are no files selected for viewing
51 changes: 51 additions & 0 deletions
51
...mon/src/main/resources/event-type-schema/nakadi.data.streamed/nakadi.data.streamed.0.avsc
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,51 @@ | ||
| { | ||
| "name": "nakadi.data.streamed", | ||
| "type": "record", | ||
| "doc": "Stores KPI events of type nakadi.data.streamed", | ||
| "fields": [ | ||
| { | ||
| "name": "api", | ||
| "description": "This field indicates if data was streamed through low level api or high level api", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "subscription", | ||
| "description": "this is optional and is only present when streaming from a subscription", | ||
| "type": [ | ||
| "null", | ||
| "string" | ||
| ], | ||
| "default": null | ||
| }, | ||
| { | ||
| "name": "event_type", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "app", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "app_hashed", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "token_realm", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "number_of_events", | ||
| "type": "long" | ||
| }, | ||
| { | ||
| "name": "bytes_streamed", | ||
| "description": "amount of bytes streamed since last event", | ||
| "type": "long" | ||
| }, | ||
| { | ||
| "name": "batches_streamed", | ||
| "description": "amount of batches streamed since last event", | ||
| "type": "int" | ||
| } | ||
| ] | ||
| } |
27 changes: 27 additions & 0 deletions
27
...n/src/main/resources/event-type-schema/nakadi.event.type.log/nakadi.event.type.log.0.avsc
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| { | ||
| "name": "nakadi.event.type.log", | ||
| "type": "record", | ||
| "doc": "Stores KPI events of type nakadi.event.type.log", | ||
| "fields": [ | ||
| { | ||
| "name": "event_type", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "status", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "category", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "authz", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "compatibility_mode", | ||
| "type": "string" | ||
| } | ||
| ] | ||
| } |
15 changes: 15 additions & 0 deletions
15
...c/main/resources/event-type-schema/nakadi.subscription.log/nakadi.subscription.log.0.avsc
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,15 @@ | ||
| { | ||
| "name": "nakadi.subscription.log", | ||
| "type": "record", | ||
| "doc": "Stores KPI events of type nakadi.subscription.log", | ||
| "fields": [ | ||
| { | ||
| "name": "subscription_id", | ||
| "type": "string" | ||
| }, | ||
| { | ||
| "name": "status", | ||
| "type": "string" | ||
| } | ||
| ] | ||
| } |