The events subcommand runs health checks for Pulse ad-events services and displays information from the Pulse Events database (NATS). It enables you to view, manage, and troubleshoot event streams, consumers, and object stores.
To view all available subcommands and flags, run:
accelo admin hc events --help
Available Subcommands
consumer
delete
update
view
object
Default Behavior
By default, the following command lists all event streams available in NATS:
Sample Output
INFO: Running health check for Events DB
╔══════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════════╗
║ Events DB ║
╠════════════════════════════════════════════╦════════════════╦════════╦═════════════════════════════════════════╦═════════════════╣
║ STREAM NAME ║ TOTAL MESSAGES ║ OFFSET ║ LAST MESSAGE TIMESTAMP ║ TOTAL CONSUMERS ║
╠════════════════════════════════════════════╬════════════════╬════════╬═════════════════════════════════════════╬═════════════════╣
║ hive_queries_events_smokey ║ 0 ║ 0 ║ 0001-01-01 00:00:00 +0000 UTC ║ 1 ║
║ impala_agent_events_smokey ║ 6503 ║ 6503 ║ 2025-01-30 11:25:20.135115216 +0000 UTC ║ 0 ║
║ impala_coord_events_offset_smokey ║ 0 ║ 0 ║ 0001-01-01 00:00:00 +0000 UTC ║ 0 ║
║ yarn_containers_rminterface_metrics_smokey ║ 0 ║ 0 ║ 0001-01-01 00:00:00 +0000 UTC ║ 1 ║
╚════════════════════════════════════════════╩════════════════╩════════╩═════════════════════════════════════════╩═════════════════╝
Commonly Used Flags
Flag | Description |
|---|
-s <stream-name> | Displays detailed information for a specific stream |
-d <url> | URL where ad-events is running (default: http://localhost:19009) |
Consumer Commands
List Consumers
Lists all consumers for a given stream.
accelo admin hc events consumer -s <stream-name>
Consumer Info
Displays detailed information for a specific consumer.
accelo admin hc events consumer info -s <stream-name> -c <consumer-name>
For example:
accelo admin hc events consumer info -s impala_agent_events_odp_smokey -c impala_coord_odp_smokey
Sample output:
╔════════════════════════════════════════════════════════════╗
║ Consumer Info ║
╠══════════════════╦═════════════════════════════════════════╣
║ Consumer Name ║ impala_coord_odp_smokey ║
║ Stream Name ║ impala_agent_events_odp_smokey ║
║ Durable Name ║ impala_coord_odp_smokey ║
║ Pending Messages ║ 0 ║
║ Ack Pending ║ 0 ║
║ Waiting ║ 1 ║
║ Redelivered ║ 0 ║
║ Date Created ║ 2025-01-31 06:12:46.366355429 +0000 UTC ║
╚══════════════════╩═════════════════════════════════════════╝
Delete Consumer
Deletes a consumer from a stream.
accelo admin hc events consumer delete -s <stream-name> -c <consumer-name>
To verify deletion, run the consumer list command again.
Delete Stream
Deletes a stream from NATS.
accelo admin hc events delete -s <stream-name>
To confirm deletion, rerun the stream list command.
Update Stream
Updates the configuration of an existing stream.
accelo admin hc events update -s <stream-name> -m <max-messages>
For example:
accelo admin hc events update -s impala_agent_events_odp_smokey -m 10000
Sample Output:
INFO: Stream 'impala_agent_events_odp_smokey' updated successfully
View Stream Data
Displays subject data for a given offset.
accelo admin hc events view -s <stream-name> -o <offset>
For example:
accelo admin hc events view -s yarn_apps_events_last_probe_odp_smokey -o 8591
Sample Output:
[8593] Subject: yarn_apps_events_last_probe_odp_smokey Received: 2025-02-03T11:27:04+05:30
1738562194018,1738562224058
Object Store Commands
The object subcommand manages NATS object stores associated with events.
List Object Stores
accelo admin hc events object
Sample Output:
INFO: List of object stores:
impala_profiles_events_odp_kafka3x
impala_test
test
If the name of the object store is provided along with the above mentioned command then it returns object Store info.
[root@odppulse401:acceldata (ad-default)]$ ./accelo admin hc events object -s impala_profiles_events_odp_kafka3x
INFO: objectStore 'impala_profiles_events_odp_kafka3x' info:
BucketName: impala_profiles_events_odp_kafka3x
Replica: 1
TTL: 1.00 days
Sealed: false
Size: 1547184623 bytes
Object Store Info
Displays details for a specific object store.
accelo admin hc events object -s <object-store-name>
Delete Object Store
Deletes an object store, if it exists.
accelo admin hc events object delete -s <object-store-name>
Watch Object Store
Streams live events for an object store.
accelo admin hc events object watch -s <object-store-name>
List Objects
Lists all objects in an object store.
accelo admin hc events object list -s <object-store-name>
Get Object Data
Loads object data into memory. You can redirect the output to a file if needed.
accelo admin hc events object get -s <object-store-name> -c <object-name>
Edit Object Store Metadata
Updates object store metadata such as size, replicas, or TTL.
accelo admin hc events object edit -s <object-store-name> [flags]
Available flags:
Flag | Description |
|---|
-m, --max-bytes | Maximum object store size (default: -1) |
-r, --replicas | Number of replicas (default: 1) |
-t, --ttl | Time to live in seconds (default: 86400) |
