Azkarra Streams CloudEvents Example

azkarra-cloudevents-example.json

{
  "id": "appid:basic-word-count-0-8-0;appsrv:localhost:8080;ts:1600959526290",
  "source": "arn://kafka=s0wwlkImS6CZ4SQ7gOM9eA/host=localhost/port=8080",
  "subject": "arn://kafka=s0wwlkImS6CZ4SQ7gOM9eA/host=localhost/port=8080/streams=basic-word-count-0-8-0",
  "specversion": "1.0",
  "type": "io.streamthoughts.azkarra.streams.stateupdateevent",
  "time": "2020-09-24T14:58:46.290+0000",
  "datacontenttype": "application/json",
  "data": {
    "state": "RUNNING",
    "threads": [
      {
        "name": "basic-word-count-0-8-0-52e54af1-fd27-4275-8824-d34423791295-StreamThread-1",
        "state": "RUNNING",
        "active_tasks": [
          {
            "task_id": "1_0",
            "topic_partitions": [
              {
                "topic": "basic-word-count-0-8-0-count-repartition",
                "partition": 0
              }
            ]
          },
          {
            "task_id": "0_0",
            "topic_partitions": [
              {
                "topic": "streams-plaintext-input",
                "partition": 0
              }
            ]
          }
        ],
        "standby_tasks": [],
        "clients": {
          "admin_client_id": "basic-word-count-0-8-0-52e54af1-fd27-4275-8824-d34423791295-admin",
          "consumer_client_id": "basic-word-count-0-8-0-52e54af1-fd27-4275-8824-d34423791295-StreamThread-1-consumer",
          "producer_client_ids": [
            "basic-word-count-0-8-0-52e54af1-fd27-4275-8824-d34423791295-StreamThread-1-producer"
          ],
          "restore_consumer_client_id": "basic-word-count-0-8-0-52e54af1-fd27-4275-8824-d34423791295-StreamThread-1-restore-consumer"
        }
      }
    ],
    "offsets": {
      "group": "basic-word-count-0-8-0",
      "consumers": []
    },
    "stores": [
      {
        "name": "count",
        "positions": [
          {
            "partition": 0,
            "current_offset": 13,
            "log_end_offset": 13,
            "offset_lag": 0
          }
        ]
      }
    ],
    "state_changed_time": 1600959496253
  },
  "ioazkarramonitorintervalms": 10000,
  "ioazkarrastreamsappid": "basic-word-count-0-8-0",
  "ioazkarraversion": "0.8.0",
  "ioazkarrastreamsappserver": "localhost:8084"
}