[jira] [Resolved] (KAFKA-5997) acks=all does not seem to be honoured

2017-09-30 Thread Ronald van de Kuil (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ronald van de Kuil resolved KAFKA-5997. --- Resolution: Not A Bug > acks=all does not seem to be honoured >

[jira] [Created] (KAFKA-5998) /.checkpoint.tmp Not found exception

2017-09-30 Thread Yogesh BG (JIRA)
Yogesh BG created KAFKA-5998: Summary: /.checkpoint.tmp Not found exception Key: KAFKA-5998 URL: https://issues.apache.org/jira/browse/KAFKA-5998 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #3998: Fix array index out of bounds

2017-09-30 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/kafka/pull/3998 Fix array index out of bounds This array access might be out of bounds, as the index might be equal to the array length. You can merge this pull request into a Git repository by running: $ git

[jira] [Created] (KAFKA-5997) acks=all does not seem to be honoured

2017-09-30 Thread Ronald van de Kuil (JIRA)
Ronald van de Kuil created KAFKA-5997: - Summary: acks=all does not seem to be honoured Key: KAFKA-5997 URL: https://issues.apache.org/jira/browse/KAFKA-5997 Project: Kafka Issue Type:

[GitHub] kafka pull request #3996: KAFKA-5746; Return 0.0 from Metric.value() instead...

2017-09-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3996 ---

Re: How is CorrelationId used for matching request and response

2017-09-30 Thread Javed, Haseeb
Thanks all for reaching out. Ted - I am looking at the 0.11.0 release. Particularly here https://github.com/apache/kafka/blob/0.11.0/clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java In this release, the Server uses the following method in almost all cases

Re: How is CorrelationId used for matching request and response

2017-09-30 Thread Ismael Juma
Hi Haseeb, That is the point, the server should always send a response with the same correlation id as the request it has received. If there's a bug in the networking layer where a response is never sent back or there is reordering somewhere in the stack, then this will be identified by the

Re: How is CorrelationId used for matching request and response

2017-09-30 Thread Jay Kreps
Yes the idea of the correlation id is to make it easier for the client to match a particular response to the request it answers. Kafka’s protocol allows sending multiple requests without waiting for the response. In theory you can just rely on ordering, but that can be a bit fragile if the client