Products | Versions |
---|---|
TIBCO BusinessEvents Enterprise Edition | 6.x |
The Kafka message can be processed twice by the InferenceAgent when AutoCommit set to true for the Kafka input destination and in-built cache has been enabled.
This is a configuration issue, by default, the Kafka message will be committed in a separate thread as part of the PostRTC actions. Due to this the worker thread receives and process the same message again when pull the next message from the Kafka topic.
To avoid the issue there are two options available.
1. Disable enableParallelOps so that the original message is committed by the same worker thread itself.
To disable add CDD property "Agent.<agentname>.enableParallelOps" for the Inference-Agent classes and set the value to false.
e.g., - if Inference agent class name is "inference-class"
<property name="Agent.inference-class.enableParallelOps" value="true"/>