# developing-kafka-python-client

> Claude/Codex skill by [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars · Updated 2026-10-06

Use when the user wants to build a Python Kafka producer or consumer, add Schema Registry to existing Python code, migrate from raw JSON to schema-backed serialization, or scaffold a confluent-kafka-python project for Confluent Cloud, local Docker, or WarpStream. Also use when user wants to optimize Python Kafka client configuration for WarpStream.

Tags: ai, cdc, confluent, confluent-cloud, flink, flinksql, kafka, kafka-streams, skills

## Install

```sh
git clone https://github.com/confluentinc/agent-skills /tmp/agent-skills && ln -s /tmp/agent-skills/skills/developing-kafka-python-client ~/.claude/skills/developing-kafka-python-client
```

## From README

Confluent Kafka Python Client Creation Generate a production-ready Python project for producing to and/or consuming from Kafka using confluent-kafka-python. Supports three target environments: Confluent Cloud (managed), Local Docker (open-source Kafka), and WarpStream (Kafka-compatible, object-storage-backed), and two producer styles: AsyncIO (non-blocking) and Synchronous (blocking). The generated code follows Confluent's best practices. Step 1: Gather Requirements Before generating any code, work through the questions below. Skip any question the user has already answered explicitly in their prompt — do not re-ask just for form's sake. For example, "build a producer and consumer on Confluent Cloud with an async producer" already answers \#2, \#3, and \#4; only \#1, \#5, \#6, \#7, and \#8 remain. Mandatory confirmation gate — do not skip, even if the user answered every question.

## Links

- HTML page: https://omgskills.com/library/confluentinc/agent-skills/skills/developing-kafka-python-client/
- GitHub: https://github.com/confluentinc/agent-skills
- Author: [@confluentinc](https://omgskills.com/library/confluentinc/index.md)

## More from this repo

- [confluent-cloud-cdc-tableflow](https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-cloud-cdc-tableflow/index.md) — Set up end-to-end Change Data Capture (CDC) pipelines on Confluent Cloud using Debezium source connectors, Flink for...
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars
- [confluent-cloud-flink-sql](https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-cloud-flink-sql/index.md) — Used to write and debug Flink SQL that runs on Confluent Cloud, enforcing the CC-vs-Apache-Flink (OSS) dialect boundary.
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars
- [confluent-tuning-advisor](https://omgskills.com/library/confluentinc/agent-skills/skills/confluent-tuning-advisor/index.md) — Advisory-only Kafka tuning for Confluent Cloud or Confluent Platform by priority: latency, throughput, availability, or...
   - [@confluentinc](https://omgskills.com/library/confluentinc/index.md) · 59 stars