Apache Kafka topic reference for HCL Universal Orchestrator
Reference for the HCL Universal Orchestrator Apache Kafka messaging topology that lists the required topics, consumer groups, and producer and consumer microservices for each topic.
The messaging pipeline for HCL Universal Orchestrator relies on a predefined layout of Apache Kafka topics. Each topic coordinates asynchronous state exchange, tracing, and command dispatch across the microservice stack.
All topic names in this reference are base names. When the optional
kafka.prefix parameter is set in the
values.yaml file of the hcl-uno-chart,
its value is prepended to every topic name. The default value is empty. Configure a
topic prefix to run multiple HCL Universal Orchestrator instances
on a single Apache Kafka server
without topic name collisions.
In environments where automatic topic creation is disabled, you must create these topics manually before deploying HCL Universal Orchestrator. For instructions, see Configuring Apache Kafka topics manually.
The following table lists every core topic required by the runtime environment, with the associated consumer groups, producer microservices, consumer microservices, and operational scope.
| Topic | Consumer Group | Producer Microservice(s) | Consumer Microservice(s) | Operational Scope |
|---|---|---|---|---|
agent-gateway-notifications |
agent-manager-consume-agent-gateway-notifications-group |
uno-agentmanager/uno-agentmanager-service |
— | Notification delivery and update events. |
agentic-builder-tenant |
N/A | uno-saas/uno-tenantmanager-service |
— | UnO Agentic AI Builder tenant lifecycle events. |
ai-agent-conversation |
orchestrator-consume-aiAgentConversationChannel |
uno-orchestrator/uno-aiagent |
— | AI agent invocation, conversation, and timeout events. |
ai-agent-invoke |
orchestrator-consume-aiAgentInvokeChannel |
uno-orchestrator/uno-orchestrator |
uno-orchestrator/uno-aiagent |
AI agent invocation, conversation, and timeout events. |
ai-agent-tool-timeout |
orchestrator-consume-aiAgentToolTimeoutChannel |
uno-orchestrator/uno-aiagent |
— | AI agent invocation, conversation, and timeout events. |
audit |
|
|
|
Audit trail events for compliance and traceability. |
clean-up |
agent-manager-consume-clean-up-group |
uno-agentmanager/uno-agentmanager-service |
— | Cleanup commands and events for maintenance workflows. |
cloud-executor-action |
N/A | uno-agentmanager/uno-agentmanager-service |
uno-executor/uno-executor-service |
Actions dispatched to cloud executor workers. |
consumed-jobs |
tenantmanager-consume-consumed-jobs-group |
|
uno-saas/uno-tenantmanager-service |
Consumed tasks counters and events for tenant-level tracking. |
errors |
N/A |
|
|
Cross-service error events for centralized diagnostics. |
eventmanager-agent-config-change |
|
uno-eventmanager/uno-eventmanager-service |
|
Event Manager pipeline, command, and processing events. |
eventmanager-build-event-rule-command |
eventmanager-consume-refreshEventRuleChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-cleanup |
eventmanager-consume-eventManagerCleanupChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-event |
eventmanager-consume-eventChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-event-audit |
eventmanager-consume-eventChannel-saving |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-event-processor |
eventmanager-consume-eventProcessorChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-run-actions-command |
eventmanager-consume-runActionsChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-run-actions-retry-command |
eventmanager-consume-runActionsRetryChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
eventmanager-source-connection |
eventmanager-consume-eventSourceConnectionChannel |
uno-eventmanager/uno-eventmanager-service |
— | Event Manager pipeline, command, and processing events. |
human-task-activate |
human-task-activate-consumer-group |
uno-orchestrator/uno-humantask |
— | Human task activation events. |
job-recovery |
orchestrator-consume-jobRecoveryChannel |
uno-orchestrator/uno-orchestrator |
— | Task recovery and service integration events. |
job-submission |
scheduler-consume-job-submission-group |
uno-orchestrator/uno-orchestrator |
uno-scheduler/uno-scheduler-service |
Task submission and related tracking events. |
job-submission-tracker |
scheduler-consume-job-submission-tracker-group |
|
uno-scheduler/uno-scheduler-service |
Task submission and related tracking events. |
jobstream-activate |
orchestrator-consume-jobStreamActivateChannel |
uno-orchestrator/uno-orchestrator |
— | Workflow control and activation events. |
jobstream-command |
orchestrator-consume-jobStreamCommandChannel |
|
uno-orchestrator/uno-orchestrator |
Workflow control and activation events. |
metrics |
toolbox-consume-metrics-group |
|
uno-toolbox/uno-metrics |
Operational metrics events for monitoring pipelines. |
notification |
consume-audit-notification-event-message-group |
uno-notification/uno-notification-service |
— | Notification delivery and update events. |
notifications |
— |
|
— | Notification delivery and update events. |
pilot-notification-update |
notification-consume-pilot-notification-update-group |
|
|
Notification delivery and update events. |
planning-actions |
orchestrator-consume-planning-actions |
uno-orchestrator/uno-orchestrator |
— | Planning action events for orchestration decisions. |
provisioning-activity-outbox |
N/A | uno-saas/uno-tenantmanager-service |
— | Tenant provisioning activity outbox events. |
resource |
scheduler-consume-resource-group |
|
uno-scheduler/uno-scheduler-service |
Resource-related scheduling and orchestration events. |
task-status-update |
scheduler-task-status-update-group |
uno-agentmanager/uno-agentmanager-service |
uno-scheduler/uno-scheduler-service |
Task run status updates from runtime components. |
task-submission |
agent-manager-consume-task-submission-group |
uno-scheduler/uno-scheduler-service |
uno-agentmanager/uno-agentmanager-service |
Task submission commands for agent run workflows. |
timer-request |
N/A | — | uno-timer/uno-timer-service |
Timer trigger requests consumed by the timer service. |
unica |
N/A | uno-saas/uno-tenantmanager-service |
— | Unica integration events managed by the tenant manager. |