Thank you for your response. I have gone through the protocol wiki. Now I have some understanding of it. Sorry for again asking the question.
I want to know, Is it possible: Let say, I have producer PA,PB,PC. They send request messages A,B,C respectively. Now these messages goes to topic. There are few consumers that took message from topic and do some computation on message. Let say after computation request A,B,C becomes AA,BB,CC respectively. Now I want to send this response to Producer A,B,C respectively. Is it possible? if yes. Can You please explain in bit detail. Thank you so much Regards Lavish Goel On Sat, Sep 20, 2014 at 10:18 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Also you can take a look at the SimpleConsumer and SyncProducer > implementation. > > On Sat, Sep 20, 2014 at 9:47 AM, Guozhang Wang <wangg...@gmail.com> wrote: > >> You can take a look at the protocol wiki to understand the request / >> response data types. Kafka server accepts socket connection for requests. >> >> Guozhang >> >> On Fri, Sep 19, 2014 at 10:42 PM, lavish goel <lavis...@gmail.com> wrote: >> >>> Thank you for your response. I want to implement request/response type >>> model. >>> For eg. I have a producer that publish a message(He wants to know some >>> status) to topic. A consumer pulls the message and processes the request. >>> Now I want that, the response of this request should go that producer. Can >>> you please tell me how can I implement this. >>> >>> Thanks >>> Lavish >>> >>> On Sat, Sep 20, 2014 at 1:26 AM, Guozhang Wang <wangg...@gmail.com> >>> wrote: >>> >>>> Do you mean that you want to know the protocol? >>>> >>>> >>>> https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol >>>> >>>> Guozhang >>>> >>>> On Fri, Sep 19, 2014 at 12:18 PM, lavish goel <lavis...@gmail.com> >>>> wrote: >>>> >>>> > Hi, >>>> > >>>> > Please tell me how to use request/response mechanism in kafka? >>>> > Thanks >>>> > Lavish Goel >>>> > >>>> >>>> >>>> >>>> -- >>>> -- Guozhang >>>> >>> >>> >> >> >> -- >> -- Guozhang >> > > > > -- > -- Guozhang >
