Streaming Data Engineer Claude Skill

Name: Bartosz - Streaming Data Engineer AI Skill
Brand: KissMySkills
Price: 19 USD
Availability: InStock

Streaming Data Engineer, Bartosz AI skill by KissMySkills, cover

Bartosz - Streaming Data Engineer AI Skill

Senior Streaming Data Engineer who treats real-time pipelines as a distinct discipline, not batch processing running faster.

$19 this skill one payment yours forever

Claude skill package instant downloadbartosz-streaming-data-engineer.skill

Library plan

Get this skill and 2,500+ others

$9/mo or $59 a year

Get Library · $9/moGet Library

Try this skill free for 7 daysTry this skill free

7-day free trial, no card
Cancel anytime
30-day money-back on your first payment

Nothing is charged. A −30% code for your first payment arrives 2 days before the trial ends.

Works inside Claude, ChatGPT, Claude Code, Codex and Cursor through one connector
Every skill, prompt pack and agent, plus AI CRM and tools during the trial
Cancel anytime

Why a subscription? How it works

Need just this skill?

One file, paid once. No updates, no connector.

Costs about the same as 2 months of Library.

$19

Pay once, keep foreverInstant download30-day money-back guarantee

As featured onProduct Hunt Fazier KittyLaunch

Works with

Secure checkout by Stripe

Trademarks of their respective owners. KissMySkills is not affiliated with or endorsed by them.

How it works

Ask Bartosz something hard.

📎 bartosz-streaming-data-engineer.skillLOADED ✓

Kafka consumer lag grows by 2M messages every evening peak, catches up by 3am. Product wants sub-minute freshness. Cheapest path?

CLAUDE · AS BARTOSZ, STREAMING DATA ENGINEER Lag that self-heals overnight is throughput, not a bug - check partition count first: if the hot topic has 6 partitions, consumer parallelism caps at 6 no matter how many instances you add. Then the consumer itself: synchronous per-message processing - an HTTP call per event is the classic - caps you at hundreds per second; batch the sink writes and it's tens of thousands. Repartitioning the hot topic to 24-48 plus batched writes usually erases a 2M backlog pattern without new hardware. Keep exactly-once only where the sink truly needs it - it costs throughput. What does the consumer do per message today?

Or have every skill inside your AI.

0:16 · no sound

Get all 2,500+ with Library · $9/mo →

Questions before you buy? A person answers, usually the same day: hello@kissmyskills.com

// the file itself

Read it before you buy it.

The first lines of the file your AI will read, exactly as delivered. Nothing rewritten for the page.

// the skill your AI runs on

You are Bartosz, a Senior Streaming Data Engineer working across Kafka, Flink, Avro and Protobuf schema registries. You have been activated to design topics, partitions, watermarks and per-partition lag monitoring that hold up under real event-time skew.

Drop Bartosz into Claude and get a Senior Streaming Data Engineer who has run Kafka and Flink in production for high-throughput event pipelines, the kind where a silent lag spike or a bad schema evolution can quietly corrupt downstream data for hours before anyone notices. Bartosz does not treat streaming as "batch, but faster." He treats it as a distinct discipline with its own failure modes: partial failures that leave state inconsistent, schema changes that break consumers without throwing a visible error, and lag that looks fine on average while a handful of partitions silently fall behind. Bartosz covers the full real-time pipeline surface: Kafka and Flink cluster and topic design, exactly-once versus at-least-once processing tradeoffs, schema registry and schema evolution (Avro/Protobuf), consumer group and partition strategy, backpressure and lag monitoring/alerting, streaming-to-warehouse landing patterns (CDC, Kafka Connect, streaming

SKILL.md · 187 lines · instant download

// what's inside

What's inside this skill

Event-time and watermark design for late data
Exactly-once and checkpointing plan for the pipeline
A diagnosis of where the duplicates come from
Operational runbook for restarts and backfills

Data engineers running Kafka and Flink pipelines without a streaming specialist

// two ways to get it

Use it inside your AI, or download it once.

Library plan

This skill and 2,500+ others, inside your chat

$9/mo cancel anytime, or $59 a year

All 2,500+ skills, prompt packs and agents, loaded the moment you ask
Nothing to download or paste: connect once in Claude, ChatGPT, Claude Code or Cursor
New skills every week and 10 catalog files a month to download

Get Library · $9/mo Try it free for 7 days

Compare Library, AI CRM and Both

Buy once

Just this skill, as a file

$19 one payment

Download after checkout and paste it into any AI chat
One file, no updates, no connector
30-day money-back guarantee

Already on Library or Both? This one is included, no need to buy the file.

Works with

Trademarks of their respective owners. KissMySkills is not affiliated with or endorsed by them.

// ask your assistant

Or let your AI set up this skill for you.

Go to kissmyskills.com/pages/connector and set up the "Bartosz - Streaming Data Engineer AI Skill" skill (handle: bartosz-streaming-data-engineer) for me

Paste it into Claude, ChatGPT, Claude Code, Cursor or Codex. Your AI walks you through connecting KissMySkills (about 3 minutes, 7-day free trial) and loads the skill. What your AI will read →

What you're actually buying

Senior Streaming Data Engineer who treats real-time pipelines as a distinct discipline, not batch processing running faster.

Bartosz covers the full real-time pipeline surface: Kafka and Flink cluster and topic design, exactly-once versus at-least-once processing tradeoffs, schema registry and schema evolution (Avro/Protobuf), consumer group and partition strategy, backpressure and consumer lag monitoring, streaming-to-warehouse landing patterns (CDC, Kafka Connect, streaming inserts), and stream processing job design (windowing, watermarks, stateful aggregation).

Who it's for

Data engineers, platform leads, and streaming-pipeline owners who need Kafka/Flink topic design, processing guarantees, and lag monitoring tied to real freshness and ordering requirements, not a copy-pasted default.

Key capabilities

Kafka/Flink topic, partition, and processing-guarantee design mapped to real duplicate/drop cost
Schema registry compatibility checks that catch a downstream consumer break, not just a registry pass
Per-partition consumer lag and backpressure monitoring, not misleading aggregate lag
CDC, Kafka Connect, or streaming-insert landing pattern chosen per freshness and volume need
Windowing, watermark, and checkpoint/savepoint recovery design verified before go-live

How to use it

Paste Bartosz's SKILL.md into your Claude Project Instructions (or any AI system prompt), then describe your Streaming Data Engineer problem. Works with Claude, ChatGPT, and any AI chat. Under 2 minutes to install.

// how to install Under 2 minutes

Four steps. Any AI chat.

01
Download the file
After checkout, the download link lands in your inbox. Save the .skill file: Claude takes it as it is.
02
Open your AI chat
Any AI chat you already use: Claude, ChatGPT, Gemini, Grok, Copilot or another.
03
Add it to your AI
Claude: Settings → Capabilities → Skills, upload the .skill file. ChatGPT, Gemini and others: open the .skill file like a .zip archive and paste SKILL.md into custom instructions or Project instructions.
04
Start working
Your AI is now configured as a specialist. Ask it anything inside its domain.

No technical knowledge required.

With Library there is nothing to download. Connect your AI once, then just ask: "Load Bartosz from KissMySkills."

Setup guide → Library · $9/mo →

// faq

Questions about this product

What AI tools does this work with?+

Claude, ChatGPT, or any AI chat that accepts a system prompt or project instructions. Claude Projects gives the best results.

How do I install it?+

Paste the SKILL.md content into your Claude Project Instructions or your AI's system prompt. Under 2 minutes, no setup required.

Is this a course or a tool?+

It's a skill file, not a course. One file that turns your AI into a configured Streaming Data Engineer ready to work on your Streaming Data Engineer problem immediately.

Our consumer lag looks fine on average but something is clearly falling behind, what does Bartosz check?+

Bartosz never trusts an aggregate lag number. He checks per-partition consumer lag directly, since a single stuck partition hides completely inside a healthy-looking average, and that's the failure mode he flags first.