Hi, I've fixed and tested the $subject in the Python Cartridge Agent. Now when the following parameters are set in the agent.conf configuration file, the LogPublisher job will be activated, which will scan the specified logs every 1 second and publish each entry as a Thrift event to the specified thrift receiver.
enable.data.publisher =true monitoring.server.ip =localhost monitoring.server.port =7611 monitoring.server.secure.port =7711 monitoring.server.admin.username =admin monitoring.server.admin.password =admin log.file.paths =/home/chamilad/dev/wso2esb-4.8.1/repository/logs/wso2carbon.log I have verified the functionality using the Integration test for the PCA. When verifying the VM and the Kubernetes end-to-end scenario, this functionality can be again tested for any unseen edge cases. I used a standalone WSO2 BAM server as the monitoring server. However, any Thrift receiver can be used as the publishing endpoint for Log publishing. Regards, Chamila de Alwis Software Engineer | WSO2 | +94772207163 Blog: code.chamiladealwis.com