kafka
Manage Apache Kafka — topics, consumer groups, and produce/consume messages via the Confluent REST Proxy.
소스 정보
- 저장소
- ThinkfleetAI/thinkfleet-engine
- 최근 소스 활동
- 2026년 2월 1일 16:21
- 감지된 SKILL.md 언어
- 영어
- 스타
- 0
- 포크
- 0
설치 방법
기본적으로 소스를 먼저 확인하는 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에서 보기