nsls2_kafka_publisher_example.py

import nslsii
from bluesky_kafka import Publisher
import uuid
from tiled.client import from_profile

c = from_profile("ucal")
config = nslsii._read_bluesky_kafka_config_file(config_file_path="/etc/bluesky/kafka.yml")
pub = Publisher(topic="ucal.bluesky.runengine.documents",
                bootstrap_servers=",".join(config['bootstrap_servers']),
                key=str(uuid.uuid4()),
                producer_config=config['runengine_producer_config'],
                flush_on_stop_doc=True)
run = c[-1]
for name, doc in run.documents():
    pub(name, doc)