You configure an instance of the Kafka cron task for each of your
Kafka queues. The cron
task consumes Kafka
messages based on the schedule that you specify. All message consumption is controlled by the
Kafka cron task.
Kafka cron task setup
The
Kafka cron task consumes messages according to whether the queue is
sequential or continuous. In the Cron Task Setup application, add one or more instances of the
Kafka cron task. Define the cron task schedule, administrative user to notify
about problems, whether the cron is active, and whether to keep history. For each instance, specify
values for the following properties:
| Property |
Description |
Default |
| TOPIC |
The name of the Kafka topic. This value is
required. |
None |
| MESSAGEHUB |
The name of the Kafka provider that is registered
in the product. This value is required. |
None |
| MESSAGEPROCESSOR |
The message processor. The same message processor is used for JMS processing. This value is
optional. If no value is specified, the default values are used. |
- Inbound
- psdi.iface.jms.QueueToMaximoProcessor
- Outbound
- psdi.iface.jms.QueueToDestManagerProcessor
- Notification
- com.ibm.tivoli.maximo.notification.NotificationMessageProcessor
|
| PARTITION |
A cron task is a specific Kafka consumer instance.
The specific numeric partition that is assigned to the cron task creates a Kafka consumer that has that partition. When external systems send
messages to the
Maximo® Manage application,
Kafka partitions can potentially be used for scaling. You
can define cron tasks, which are Kafka consumers, by using
preassigned partitions during setup time. |
None |
KAFKAERROR cron task setup
The
KAFKAERRROR cron task is responsible for processing messages from the
error table in a continuous way. It should be set up only for continuous
Kafka queues.
| Property |
Description |
Default |
| TOPIC |
The name of the Kafka topic. This value is
required. |
None |
| MESSAGEPROCESSOR |
The message processor. The same message processor is used for JMS processing. This value is
optional. If no value is specified, the default values are used. |
- Inbound
- psdi.iface.jms.QueueToMaximoProcessor
- Outbound
- psdi.iface.jms.QueueToDestManagerProcessor
- Notification
- com.ibm.tivoli.maximo.notification.NotificationMessageProcessor
|