Re: question about message sets and produce requests/responses

2014-07-23 Thread Joel Koshy
Also, to be clear, by ack I mean an error code as described here: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ProduceResponse On Wed, Jul 23, 2014 at 04:33:29PM -0700, Joel Koshy wrote: > Not sure if I followed the question correctly, bu

Re: question about message sets and produce requests/responses

2014-07-23 Thread Dave Peterson
Ok, that's all I need to know. Thanks! On Wed, Jul 23, 2014 at 4:33 PM, Joel Koshy wrote: > Not sure if I followed the question correctly, but S1 and S2 would be > message-sets to different partitions of T - the producer request > object contains a map of topic-partition -> messageset). So eac

Re: question about message sets and produce requests/responses

2014-07-23 Thread Joel Koshy
Not sure if I followed the question correctly, but S1 and S2 would be message-sets to different partitions of T - the producer request object contains a map of topic-partition -> messageset). So each partition would get its own ack. The response object is just a map of partition -> response status

question about message sets and produce requests/responses

2014-07-23 Thread Dave Peterson
Hello, I have a question about produce requests and responses. Suppose I create a produce request consisting of a single topic T which contains two message sets S1 and S2, with S1 preceding S2. In other words, the request looks like this: ( request header ( T ( S1, S2 ) ) ) Is it possible t