Skip to main content
Loading navigation
Back to prompt library

Kafka Integration and Data Ingestion Agent

Linked challenge: Real-time Weather Prediction Agents

Prompt source

implementation1 lines1 sectionsNo variables0 checklist items
Implement the 'Data Ingest Agent' to connect to an Apache Kafka topic and continuously consume simulated weather sensor data (e.g., temperature, humidity, pressure). This agent should preprocess the data and make it available for other agents. Use CrewAI's `tool` decorator to define a Kafka consumer tool and `Agent` class to define the agent's behavior for consuming and publishing processed data to an internal queue or shared state.