chore: add kafka devcontainer

.devcontainer/devcontainer.json

@@ -0,0 +1,26 @@
+// For format details, see https://aka.ms/devcontainer.json. For config options, see the
+// README at: https://github.com/devcontainers/templates/tree/main/src/python
+{
+	"name": "Python 3",
+	"service": "python-3.12-faststream-studio",
+	"dockerComposeFile": [
+        "./docker-compose.yaml"
+    ],
+	"shutdownAction": "stopCompose",
+	"forwardPorts": [
+        "kafka-faststream:9092"
+    ],
+	"updateContentCommand": "bash .devcontainer/setup.sh",
+	"workspaceFolder": "/workspaces/faststream"
+	// Features to add to the dev container. More info: https://containers.dev/features.
+	// "features": {},
+
+	// Use 'postCreateCommand' to run commands after the container is created.
+	// "postCreateCommand": "pip3 install --user -r requirements.txt",
+
+	// Configure tool-specific properties.
+	// "customizations": {},
+
+	// Uncomment to connect as root instead. More info: https://aka.ms/dev-containers-non-root.
+	// "remoteUser": "root"
+}

.devcontainer/docker-compose.yaml

@@ -0,0 +1,33 @@
+version: '3'
+
+services:
+  python-3.12-faststream-studio:
+    image: mcr.microsoft.com/devcontainers/python:3.12
+    container_name: python-3.12-faststream-studio
+    volumes:
+      - ../:/workspaces/faststream:cached
+    command: sleep infinity
+    network_mode: "host"
+
+  kafka-faststream:
+    image: bitnami/kafka:3.5.0
+    container_name: kafka-faststream
+    ports:
+      - 9092:9092
+    environment:
+      KAFKA_ENABLE_KRAFT: "true"
+      KAFKA_CFG_NODE_ID: "1"
+      KAFKA_CFG_PROCESS_ROLES: "broker,controller"
+      KAFKA_CFG_CONTROLLER_LISTENER_NAMES: "CONTROLLER"
+      KAFKA_CFG_LISTENERS: "PLAINTEXT://:9092,CONTROLLER://:9093"
+      KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: "CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"
+      KAFKA_CFG_ADVERTISED_LISTENERS: "PLAINTEXT://127.0.0.1:9092"
+      KAFKA_BROKER_ID: "1"
+      KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: "1@kafka-faststream:9093"
+      ALLOW_PLAINTEXT_LISTENER: "true"
+    networks:
+      - faststream-network
+
+networks:
+  faststream-network:
+    name: "${USER}-faststream-network"

.devcontainer/setup.sh

@@ -0,0 +1,7 @@
+pip install uv
+
+uv venv .venv
+
+uv pip install -e ".[dev]"
+
+source .venv/bin/activate

.github/dependabot.yml

@@ -0,0 +1,14 @@
+version: 2
+updates:
+  - package-ecosystem: "github-actions"
+    directory: "/"
+    schedule:
+      interval: "weekly"
+  - package-ecosystem: "pip"
+    directory: "/"
+    schedule:
+      interval: "weekly"
+  - package-ecosystem: "devcontainers"
+    directory: "/"
+    schedule:
+      interval: weekly

serve.py

@@ -0,0 +1,5 @@
+from faststream import FastStream
+from faststream.kafka import KafkaBroker
+
+broker = KafkaBroker()
+app = FastStream(broker)

tests/brokers/confluent/test_test_reentrancy.py

@@ -51,7 +51,7 @@ async def on_output_data(msg: int):
     async with TestKafkaBroker(broker) as tester:
         await tester.publish(1, "input_data")
 
-        await on_output_data.wait_call(3)
+        await on_output_data.wait_call(10)
 
         on_input_data.mock.assert_called_with(1)
         to_output_data.mock.assert_called_with(2)

tests/docs/getting_started/publishing/test_broker_context.py

@@ -38,7 +38,7 @@ async def test_broker_context_confluent():
     from faststream.confluent import TestKafkaBroker as TestConfluentKafkaBroker
 
     async with TestConfluentKafkaBroker(broker, with_real=True), TestApp(app):
-        await handle.wait_call(5)
+        await handle.wait_call(10)
         handle.mock.assert_called_once_with("Hi!")