> ## Documentation Index
> Fetch the complete documentation index at: https://docs.allium.so/llms.txt
> Use this file to discover all available pages before exploring further.
# Quickstart
> Create, deploy, and consume your first Beam pipeline in minutes.
**Beta access required.** Beam is in beta. Contact [support@allium.so](mailto:support@allium.so) to request access before you begin.
## Create your first pipeline
Go to [app.allium.so/build/beam](https://app.allium.so/build/beam) and click **New** for a blank pipeline, or **Start with Template** to begin from an example.
Select a blockchain and entity to stream. For example, choose **Polygon** and **log** to stream every Polygon log.
Add a **Set Filter** to keep only the events you care about. Choose the field to match on.
For example, to keep only USDC on Polygon, set the expression to `root = this.address`. Click **Edit** on the filter node and add the USDC contract address. You can add values one at a time, paste a list, or upload a `.txt` or `.csv` file.
Add a **Kafka** sink and name it, for example `usdc-logs`. The name becomes part of the topic you consume from.
Click **Deploy**. Beam provisions your Kafka topic and credentials and starts the pipeline, usually in under 30 seconds.
Once deployed, click **Get Cooking** to view your Kafka credentials and consumer code samples.
```python Python theme={null}
from confluent_kafka import Consumer
conf = {
"bootstrap.servers": "",
"group.id": "",
"security.protocol": "SASL_SSL",
"sasl.mechanisms": "PLAIN",
"sasl.username": "",
"sasl.password": "",
"auto.offset.reset": "latest",
}
consumer = Consumer(conf)
consumer.subscribe(["beam..usdc-logs"])
while True:
msg = consumer.poll(1.0)
if msg is None:
continue
print(msg.value().decode("utf-8"))
```
```typescript TypeScript theme={null}
import { Kafka } from "kafkajs";
const kafka = new Kafka({
brokers: [""],
ssl: true,
sasl: {
mechanism: "plain",
username: "",
password: "",
},
});
const consumer = kafka.consumer({ groupId: "" });
await consumer.connect();
await consumer.subscribe({ topic: "beam..usdc-logs" });
await consumer.run({
eachMessage: async ({ message }) => {
console.log(message.value?.toString());
},
});
```
Replace the placeholders with the values from the **Get Cooking** panel.
## Verify your deployment
Check worker health in the Beam UI after deploying:
* **Total workers**: workers running for the pipeline
* **Healthy workers**: workers processing data normally
* **Unhealthy, crashing, or out of memory**: should all be 0
Open the **Metrics** panel to confirm messages are flowing over the last hour, day, or week.
## Updating a pipeline
Edit the source, transforms, or sinks in the UI and click **Deploy** again. Deploys are **idempotent and zero-downtime**; changes apply in place.
Don't tear down before redeploying. Tearing down causes unnecessary downtime.
## Next steps
Sources, transforms, and sinks
Ready-to-use pipeline configs for common use cases