Back to Prompt Library
implementation

Kafka Integration and Data Ingestion Agent

Inspect the original prompt language first, then copy or adapt it once you know how it fits your workflow.

Linked challenge: Real-time Weather Prediction Agents

Format
Code-aware
Lines
1
Sections
1
Linked challenge
Real-time Weather Prediction Agents

Prompt source

Original prompt text with formatting preserved for inspection.

1 lines
1 sections
No variables
0 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.

Adaptation plan

Keep the source stable, then change the prompt in a predictable order so the next run is easier to evaluate.

Keep stable

Hold the task contract and output shape stable so generated implementations remain comparable.

Tune next

Update libraries, interfaces, and environment assumptions to match the stack you actually run.

Verify after

Test failure handling, edge cases, and any code paths that depend on hidden context or secrets.