service messagebus (Kafka)
Syntax
service messagebus config <option>
service messagebus log-analytics <option>
Description
Check information about config and log-analytics messagebus.
Options
| log |
Display the logs of messagebus. |
| repair |
Repair messagebus. |
| reset-topic |
Reset the messagebus topics. |
| restart |
Restart messagebus. |
| status |
Check the status of messagebus. |
| export diagnostics | Export the messagebus diagnostics. |
Required Privilege Level
CLI Administrator
Sample Output
service messagebus config
log$ service messagebus config log [2024-10-28 11:51:09,257] INFO Deleted offset index /bitnami/kafka/data/secmgt.sd-device-managed-3/00000000000000000000.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment) [2024-10-28 11:51:09,257] INFO Deleted time index /bitnami/kafka/data/secmgt.sd-device-managed-3/00000000000000000000.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment) [2024-10-28 11:51:09,258] INFO [LocalLog partition=ems.anti_virus_profile-3, dir=/bitnami/kafka/data] Deleting segment files LogSegment(baseOffset=0, size=4479, lastModifiedTime=1729511269735, largestRecordTimestamp=1729511269725) (kafka.log.LocalLog$) [2024-10-28 11:51:09,258] INFO Deleted log /bitnami/kafka/data/ems.anti_virus_profile-3/00000000000000000000.log.deleted. (org.apache.kafka.storage.internals.log.LogSegment) [2024-10-28 11:51:09,258] INFO Deleted offset index /bitnami/kafka/data/ems.anti_virus_profile-3/00000000000000000000.index.deleted. (org.apache.kafka.storage.internals.log.LogSegment) [2024-10-28 11:51:09,258] INFO Deleted time index /bitnami/kafka/data/ems.anti_virus_profile-3/00000000000000000000.timeindex.deleted. (org.apache.kafka.storage.internals.log.LogSegment) .......
service messagebus log-analytics
log$ service messagebus log-analytics log [2024-10-27 02:20:07,329] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001007867-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) [2024-10-27 02:20:07,331] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001007867-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter) [2024-10-27 03:20:07,620] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001015066-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) [2024-10-27 03:20:07,622] INFO [SnapshotEmitter id=0] Successfully wrote snapshot 00000000000001015066-0000000001 (org.apache.kafka.image.publisher.SnapshotEmitter) [2024-10-27 04:20:07,873] INFO [SnapshotGenerator id=0] Creating new KRaft snapshot file snapshot 00000000000001022265-0000000001 because we have waited at least 60 minute(s). (org.apache.kafka.image.publisher.SnapshotGenerator) ......
service messagebus config
status$ service messagebus config status config: Status is up and running config: Validating messages are processing config: Messages are processing. Service is healthy
service messagebus
log-analytics
status$ service messagebus log-analytics status log-analytics: Status is up and running log-analytics: Validating messages are processing log-analytics: Messages are processing. Service is healthy
Release Information
Command introduced in Juniper Security Director Release 24.4.1.