kafka
Manage Apache Kafka — topics, consumer groups, and produce/consume messages via the Confluent REST Proxy.
Informations de source
- Dépôt
- ThinkfleetAI/thinkfleet-engine
- Dernière activité de la source
- 1 février 2026 à 16:21
- Langue détectée de SKILL.md
- anglais
- Étoiles
- 0
- Forks
- 0
Options d'installation
Le prompt qui vérifie d'abord la source est sélectionné par défaut. Vous pouvez passer à une commande directe ou télécharger une copie locale.
Vérifiez les fichiers source
Lisez SKILL.md et les fichiers associés affichés par SkillsMP avant de décider de l'installer.
Affichage de SKILL.md
SKILL.md
Instructions source · Aperçu en lecture seule- 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.
Voir sur GitHub