[jira] [Commented] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

2016-01-21 Thread Dave Peterson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15110837#comment-15110837 ] Dave Peterson commented on KAFKA-3088: -- Without being familiar with the code and how much work each

[jira] [Commented] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

2016-01-21 Thread Dave Peterson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112001#comment-15112001 ] Dave Peterson commented on KAFKA-3088: -- I wasn't planning on submitting a patch. I wish I could

[jira] [Created] (KAFKA-3088) 0.9.0.0 broker crash on receipt of produce request with empty client ID

2016-01-11 Thread Dave Peterson (JIRA)
Dave Peterson created KAFKA-3088: Summary: 0.9.0.0 broker crash on receipt of produce request with empty client ID Key: KAFKA-3088 URL: https://issues.apache.org/jira/browse/KAFKA-3088 Project: Kafka

automatic topic creation question

2014-09-26 Thread Dave Peterson
I have a broker cluster configured with auto.create.topics.enable=true. Observing tcpdump output while using kafka-console-producer.sh to send a message with a previously nonexistent topic, it appears that the producer instructs the broker to create the topic by sending a metadata request for that

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

Re: question about message sets and produce requests/responses

2014-07-23 Thread Dave Peterson
- messageset). So each partition would get its own ack. The response object is just a map of partition - response status so the order of acks in the response is the response status map's order. Joel On Wed, Jul 23, 2014 at 02:09:40PM -0700, Dave Peterson wrote: Hello, I have a question about

question about produce requests and responses

2014-06-11 Thread Dave Peterson
Hello, I have a question about produce requests and responses. I send a produce request containing multiple topics, and get back a response from the broker containing all topics from the request. However, the ordering of the topics in the response differs from the ordering of the topics in the

Re: produce request wire format question

2013-05-23 Thread Dave Peterson
, use it to map the key to a partition id 2.3 If a message has a key and the user has not defined a custom partitioner, use the default hash based partitioner that ships with Kafka Thanks, Neha On Wed, May 22, 2013 at 1:33 PM, Dave Peterson dspeter...@tagged.comwrote: Ok, the picture I have

produce request wire format question

2013-05-21 Thread Dave Peterson
In the version 0.8 wire format for a produce request, does a value of -1 still indicate use a random partition as it did for 0.7? Thanks, Dave

Re: produce request wire format question

2013-05-21 Thread Dave Peterson
, Dave Peterson dspeter...@tagged.comwrote: In the version 0.8 wire format for a produce request, does a value of -1 still indicate use a random partition as it did for 0.7? Thanks, Dave

Re: produce request wire format question

2013-05-21 Thread Dave Peterson
. I don't believe that you can have the broker decide which partition a message goes to. -- Colin B. On 05/21/2013 11:48 AM, Dave Peterson wrote: I'm looking at the document entitled A Guide to the Kafka Protocol located here: https://cwiki.apache.org/KAFKA/a-guide-to-the-kafka