admin tool

Example Run

----- got message -----
key:[36a613b0-8ba6-444c-8432-ea0e8adfe187], properties:[], content:{"topic":"persistent://public/default/aircraft-partition-0","schemaType":"JSON","schemaName":"aircraft-partition-0","schemaDefinition":"{\"type\":\"record\",\"name\":\"Aircraft\",\"namespace\":\"dev.pulsarfunction.adsb\",\"fields\":[{\"name\":\"alt_baro\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"alt_geom\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"baro_rate\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"category\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"emergency\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"flight\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"gs\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"gva\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"hex\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"lat\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"lon\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"mach\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"messages\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"nac_p\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"nac_v\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"nav_altitude_mcp\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"nav_heading\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"nav_qnh\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"nic\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"nic_baro\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"rc\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"rssi\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"sda\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"seen\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"seen_post\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"sil\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"sil_type\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"speed\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"squawk\",\"type\":[\"null\",\"int\"],\"default\":null},{\"name\":\"track\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"version\",\"type\":[\"null\",\"int\"],\"default\":null}]}","messageId":"24612:377:0:0","ts":1670953809183,"alertDateTime":"Dec 13, 2022","schemaVersion":4,"uuid":"36a613b0-8ba6-444c-8432-ea0e8adfe187"}
----- got message -----
key:[f55b9705-9739-442e-897c-4891348301bd], properties:[], content:{"topic":"persistent://public/default/mtaalert-partition-0","schemaType":"JSON","schemaName":"mtaalert-partition-0","schemaDefinition":"{\"type\":\"record\",\"name\":\"Alert\",\"namespace\":\"dev.datainmotion.gtfsrealtime.model\",\"fields\":[{\"name\":\"activePeriodEnd\",\"type\":\"long\"},{\"name\":\"activePeriodStart\",\"type\":\"long\"},{\"name\":\"agency\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"cause\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"descriptionLanguage\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"descriptionText\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"directionId\",\"type\":\"long\"},{\"name\":\"effect\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"feedEntityID\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"headerLanguage\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"headerText\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"routeId\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"severityLevel\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"stopId\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"tripDirectionId\",\"type\":\"long\"},{\"name\":\"tripRouteId\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"tripStartDate\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"tripStartTime\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"url\",\"type\":[\"null\",\"string\"],\"default\":null}]}","messageId":"15015:129:0","ts":1670953809188,"alertDateTime":"Dec 13, 2022","schemaVersion":0,"uuid":"f55b9705-9739-442e-897c-4891348301bd"}

References

pip3 install 'acryl-datahub[pulsar]'

https://datahubproject.io/docs/generated/ingestion/sources/pulsar/