Comment on page
A LangStream application chooses the message broker at deployment time, and the choice is made in the instance.yaml file.
The message broker is chosen in the instance.yaml file, using the "broker" section:
The LangStream runtime is pluggable and supports multiple message brokers. The current version supports Apache Kafka and Apache Pulsar but you can add your own implementation. If you're using a different message broker, you have to provide the implementation of the "streamingCluster" interface, feel free to open a GitHub issue or reach out to the community on Slack if you need help.
Last modified 28d ago