kafka
Manage Apache Kafka — topics, consumer groups, and produce/consume messages via the Confluent REST Proxy.
معلومات المصدر
- المستودع
- ThinkfleetAI/thinkfleet-engine
- آخر نشاط في المصدر
- ١ فبراير ٢٠٢٦ في ١٦:٢١
- لغة SKILL.md المكتشفة
- الإنجليزية
- النجوم
- ٠
- التفرعات
- ٠
خيارات التثبيت
يُحدَّد Prompt الذي يراجع المصدر أولًا بشكل افتراضي. يمكنك التبديل إلى أمر مباشر أو تنزيل نسخة محلية.
مراجعة ملفات المصدر
اقرأ SKILL.md وأي ملفات مرافقة يعرضها SkillsMP قبل أن تقرر التثبيت.
عرض SKILL.md
SKILL.md
تعليمات المصدر · معاينة للقراءة فقط- name
- kafka
- description
- Manage Apache Kafka — topics, consumer groups, and produce/consume messages via the Confluent REST Proxy.
- metadata
- {"thinkfleetbot":{"emoji":"📨","requires":{"bins":"[Truncated]","env":"[Truncated]"}}}
# Apache Kafka
Manage topics, consumer groups, and messages via the Confluent REST Proxy.
## List topics
```bash
curl -s "http://localhost:8082/topics" | jq '.[]'
```
## Get topic details
```bash
curl -s "http://localhost:8082/topics/TOPIC_NAME" | jq '{name, partitions: (.partitions | length), configs}'
```
## Produce message
```bash
curl -s -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" \
"http://localhost:8082/topics/TOPIC_NAME" \
-d '{"records":[{"key":"key1","value":{"message":"hello"}}]}' | jq '.offsets[]'
```
## Create consumer
```bash
curl -s -X POST -H "Content-Type: application/vnd.kafka.v2+json" \
"http://localhost:8082/consumers/my-group" \
-d '{"name":"my-consumer","format":"json","auto.offset.reset":"earliest"}' | jq '{instance_id, base_uri}'
```
## Consume messages
```bash
curl -s -H "Accept: application/vnd.kafka.json.v2+json" \
"http://localhost:8082/consumers/my-group/instances/my-consumer/records" | jq '.[] | {topic, key, value, offset}'
```
## Notes
- Requires Confluent REST Proxy running (default port 8082).
- Always confirm before producing messages.
عرض على GitHub