Skip to content

Instantly share code, notes, and snippets.

@fhussonnois
Last active May 12, 2020 12:21
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save fhussonnois/627f56920e40e815a8a514bff7e36bd0 to your computer and use it in GitHub Desktop.
Save fhussonnois/627f56920e40e815a8a514bff7e36bd0 to your computer and use it in GitHub Desktop.
Azkarra Streams - Streams State Cloud Event - Sample
{
"id": "appid:word-count;appsrv:localhost:8080;ts:1588976019636",
"source": "azkarra/ks/localhost:8080",
"specversion": "1.0",
"type": "io.streamthoughts.azkarra.streams.stateupdateevent",
"time": "2020-05-08T22:13:39.636+0000",
"datacontenttype": "application/json",
"ioazkarramonitorintervalms": 10000,
"ioazkarrastreamsappid": "word-count",
"ioazkarraversion": "0.7.0",
"ioazkarrastreamsappserver": "localhost:8080"
"data": {
"state": "RUNNING",
"threads": [
{
"name": "word-count-ab756b57-25ed-4c84-b4ef-93e9a84057ad-StreamThread-1",
"state": "RUNNING",
"active_tasks": [
{
"task_id": "0_0",
"topic_partitions": [
{
"topic": "streams-plaintext-input",
"partition": 0
}
]
}
],
"standby_tasks": [],
"clients": {}
}
],
"offsets": {
"group": "basic-word-count",
"consumers": [
{
"client_id": "basic-word-count-ab756b57-25ed-4c84-b4ef-93e9a84057ad-StreamThread-1-consumer",
"stream_thread": "basic-word-count-ab756b57-25ed-4c84-b4ef-93e9a84057ad-StreamThread-1",
"positions": [
{
"topic": "streams-plaintext-input",
"partition": 0,
"consumed_offset": 10,
"consumed_timestamp": 1588975991664,
"committed_offset": 11,
"committed_timestamp": 1588976019189,
"log_end_offset": 11,
"log_start_offset": 0,
"lag": 0
}
]
}
]
},
"state_changed_time": 1588975839528
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment