Acceldata
Pulse

Events Healthcheck Commands

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:

accelo admin hc events

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)