Kafka Integration and Data Ingestion Agent

implementationChallenge

Prompt Content

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.

Try this prompt

Open the workspace to execute this prompt with free credits, or use your own API keys for unlimited usage.

Usage Tips

Copy the prompt and paste it into your preferred AI tool (Claude, ChatGPT, Gemini)

Customize placeholder values with your specific requirements and context

For best results, provide clear examples and test different variations