Kafka Rest的示例

Question

在Java中是否有使用Kafka rest api的生產者和消費者羣體的良好示例。我不尋找生產者和消費者的簡單消費者或卡夫卡客戶端的例子。任何幫助被認可。

Answer 1

它更好地實施生產者和消費者，然後整合休息API爲生產者和消費者。

producer(){ 
//your implementation for producer 
} 

consumer(){ 
//your implementation for consumer 
} 

REST API：

@POST 
restProducer(){ 
producer(); 
} 

@GET 
restConsumer(){ 
consumer(); 
} 

--or其他

嘗試利用融合實現的REST API

http://docs.confluent.io/1.0/kafka-rest/docs/intro.html