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.