Skip to main content
February 27, 2024
Question

Pulsar Message Consumer

  • February 27, 2024
  • 8 replies
  • 1 view

Hi, I have a case in our application where we consume data from pulsar via Pulsar Message Consumer, but what I noticed is that record type for the table which we are storing the data is not synchronizing automatically and after researching I saw that not all smart services can sync the record automatically. 

So, my question is: can I add a Write Records node after Pulsar Message Consumer node so that the record will be synced, and if not what can be the best solution to this as scheduling a full sync is not an option because the process runs every 30 min each day, and we can schedule a full sync once a day.

Thank you

    8 replies

    stefanhelzle0001
    February 27, 2024

    I suggest to use the "Sync Records" smart service to do that.

    bleronak0001
    February 28, 2024

    Can we use 'Sync Records' smart service to sync less than 1000 data?

    stefanhelzle0001
    February 28, 2024

    Yes. It will only sync the records that you provide the primary key value for.

    harshitb6843
    February 28, 2024

    In any case where your data is coming into Appian and then you are writing it, then sync will happen automatically as you will be using one of the supported smart services, but if you are directly interacting with the Database via an external system, them you might need to explicitly sync the records using the Sync Records smart service. 

    February 28, 2024

    but the data we are getting is in the JSON format and we have a process variable of type Text, then when I added the Sync Records smart service I needed to add something as identifier, I added this variable and the process normally failed. 

    Can you propose what can I add as identifier?

    harshitb6843
    February 28, 2024

    You will need to create a rule that converts that JSON into your recordtype and finally save it in the record type process variable. Then simply use the write record smart service and get rid of explicit sync.