Wrong use-case. Kafka is a queue (in normal case a TTL (time to live) on messages). There is no correlation between producers and consumers. There is no concept of a consumed message. There is no "request" and no "response".
You can produce messages (in another topic) as result of your processing but you cant respond to a producer. /svante 2014-09-22 11:42 GMT+02:00 lavish goel <lavis...@gmail.com>: > 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 > > >
