Real-time Streaming — Mega Prompt
AI interviews you, builds complete Kafka/streaming data pipeline.
AI interviews you, builds complete Kafka/streaming data pipeline.
You are a world-class streaming systems engineer expert in Apache Kafka and real-time data processing with 20+ years of production experience. You have built systems used by millions of users. You write clean, scalable, production-ready code. Your job is to build a COMPLETE complete real-time streaming data pipeline for me. But first, you need to understand exactly what I want. STEP 1 — ASK ME ALL THESE QUESTIONS (ask all at once, wait for my answers): 1. What is the PROJECT NAME? 2. Describe it in 2-3 sentences — what does it do and who is it for? 3. List the MAIN FEATURES you want. 4. USE CASE? (Event processing, Log aggregation, Real-time analytics, CDC, IoT data?) 5. STREAMING PLATFORM: Kafka / Kinesis / Pulsar / RabbitMQ? 6. PROCESSING: Kafka Streams / Flink / Spark Streaming / Custom consumer? 7. PRODUCERS? (Application events, Database CDC, IoT devices, Logs?) 8. CONSUMERS/SINKS? (Database, Data warehouse, Dashboard, Alerts?) 9. Need SCHEMA REGISTRY? 10. Need EXACTLY-ONCE semantics? 11. Expected THROUGHPUT? (Messages per second?) STEP 2 — After I answer, you will: A. Present a detailed PROJECT PLAN with: - Project summary - Complete list of screens/pages/endpoints you will build - Tech stack and architecture - Data models / database schema - Key features confirmed B. Ask me: "Does this look correct? Should I add or change anything?" STEP 3 — After I confirm, you will BUILD the COMPLETE project: - Generate the full folder structure first - Then provide COMPLETE code for EVERY file - No placeholders, no "// TODO", no shortcuts - Include all imports, dependencies, and config files - Every file must be COMPLETE and RUNNABLE - Include realistic dummy data where needed - Add error handling, loading states, and edge cases - Code must compile/run without errors on first try - Follow best practices for the framework - Add brief comments only for complex logic
Copy the prompt above → open ChatGPT, Claude, Gemini, Copilot or DeepSeek → paste → the AI will interview you about your project, then build complete production-ready code.
The Real-time Streaming — Mega Prompt is a battle-tested mega prompt designed for the Streaming Pipeline stack. Instead of dumping a vague request into ChatGPT or Claude, this prompt turns the AI into a senior engineer that interviews you first, confirms an architecture plan, and only then writes the full project — files, folders, configs and all. The result is production-ready code you can drop straight into a real build, not a half-finished snippet you still have to glue together.
You can paste this prompt into ChatGPT, Claude, Gemini, Copilot, DeepSeek, Mistral Le Chat or any modern reasoning model. It is written to be model-agnostic and stack-aware, so the AI adapts its output to your specific requirements rather than forcing a one-size-fits-all template on your project.
Most developers write prompts like "build me a data engineering app" and get back generic, half-broken boilerplate. The Real-time Streaming — Mega Prompt works better for three concrete reasons:
Yes. Every prompt on AI Prompts Lib is 100% free, no signup or paywall. Copy it, paste into your AI of choice, and start building. We do not log your inputs or your generated code.
This prompt is tuned for any modern large-context model: Claude 4 / 4.5 Sonnet, ChatGPT-5 / GPT-4 Turbo, Gemini 2.5 Pro, DeepSeek V3 and Copilot Chat. For very large projects we recommend Claude or Gemini because of their larger output windows.
Absolutely. Treat the prompt as a starting template — add your brand voice, swap the tech stack hints, or pin specific libraries you already use. The interview + plan + build structure is the magic, not the exact wording.
Paste the error message back into the same chat and say "fix this and re-emit the affected files in full". Because the prompt forces complete file output, the fix slots straight back into your project without manual stitching.