SciCatProject / scicat-filewriter-ingest

Python client that connects to a kafka queue and creates new datasets when receiving notification that a file has been written
0 stars 0 forks source link

Wrdn message #26

Closed nitrosx closed 5 months ago

nitrosx commented 6 months ago

This PR adds the code to select only the WRDN message of all the message received from kafka on the topics that we are subscribed to. For the time being this is the only message that we are using.