Messaging
Last updated
Last updated
LangStream supports both and as message brokers to store and exchange data between agents.
There is also experimental support for .
A LangStream application chooses the message broker at deployment time, and the choice is made in the instance.yaml file.
You can find how to configure the topics in your application.
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.
Check out the reference configurations for and