---
# System prepended metadata

title: Kafka

---

# Kafka

  "broker": "string", 必填
  "consumerGroupID": "string", *選填*
  "topics": [ "string" ] 必填一個以上  
  
* 檢查 kafka 可否連線
* 檢查每個 topic 是否存在
* 會去拿每個 topic 最多10筆資料，如果有 topic 拿不到資料會丟 error
* consumerGroupID 如果跟上次同一個，zookeeper 會紀錄上次取到哪，會繼續往下取，所以可能會出現拿不到資料的狀況****


## Furture Work

* ssh tunnel 還沒做
* 

POST
​/kafkas add kafka
GET
​/kafkas​/{kafkaID:string}
get kafka
PUT
​/kafkas​/{kafkaID:string}
edit kafka
DELETE
​/kafkas​/{kafkaID:string}
delete kafka