Individual skill
streaming-kafka
Kafka topic and consumer group management. Use when investigating Kafka topics, consumer lag, broker health, or consumer group status.
sre-agent/.claude/skills/streaming-kafka/SKILL.md
Source commit 2323af0551856ff4669b73dc36329d16aa19ed24
What was checked
- Matches the observed repository HEAD
- Yes
- Scanner rules are current
- No
- Repository scan complete
- No
- Skill scan complete
- No
- Observed behavior
- Not checked yet
- Last checked
- Nov 7, 2026
These are observations at the recorded commit, not a guarantee of safety. Review the source before running it.
Install this skill
Choose an agent in your Stack or copy a command below. Commands fetch the pinned commit and copy only this skill directory. Existing destinations are refused. Copying a command does not install anything.
An install command is unavailable: current rules, complete repository and skill scans, an eligible behavior level and a permitted license are required.
Repository context
- Repository stars (not skill ratings)
- 179
- Repository last updated
- Nov 8, 2026
- License
- Apache-2.0
Observed agent integration: No specific integration evidence. Standard SKILL.md installation does not imply verified compatibility.
- ai-sre Repository topic
- site-reliability-engineering Repository topic
- ai-agent Repository topic
- devops Repository topic
- episodic-memory Repository topic
- incident-investigation Repository topic
- incident-response Repository topic
- knowledge-graph Repository topic
- sre-agent Repository topic
- self-hosted Repository topic
- engineering Derived category
Files and excerpt
File metadata and permitted, redacted excerpts come from the recorded scan. Source links are pinned to that commit.
Browse files
SKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesSKILL.mdcore · 2,466 bytesscripts/describe_consumer_group.pyruns · 2,530 bytesscripts/describe_topic.pyruns · 3,627 bytesscripts/get_broker_info.pyruns · 1,004 bytesscripts/get_consumer_lag.pyruns · 3,382 bytesscripts/kafka_client.pyruns · 2,424 bytesscripts/list_consumer_groups.pyruns · 998 bytesscripts/list_topics.pyruns · 1,821 bytes
Read excerpt
# Kafka Streaming
## Authentication
**IMPORTANT**: Credentials are injected automatically by a proxy layer. Do NOT check for `KAFKA_SASL_PASSWORD` in environment variables - it won't be visible to you. Just run the scripts directly; authentication is handled transparently.
Configuration environment variables you CAN check (non-secret):
- `KAFKA_BOOTSTRAP_SERVERS` - Kafka broker addresses
- `KAFKA_SECURITY_PROTOCOL` - Security protocol (PLAINTEXT, SSL, SASL_SSL, SASL_PLAINTEXT)
---
## MANDATORY: Broker-First Investigation
